dev  

Messages by Date

• 2024/08/23 [jira] [Created] (FLINK-36148) Support parsing DDL to new CreateTableEvent in binlog reading phase. LvYanquan (Jira)
• 2024/08/23 [jira] [Created] (FLINK-36147) Removes deprecated location field Matthias Pohl (Jira)
• 2024/08/23 [jira] [Created] (FLINK-36146) NoSuchElement exception from SingleThreadFetcherManager Jira
• 2024/08/23 [jira] [Created] (FLINK-36145) Change JobSpec.flinkStateSnapshotReference to snapshotReference Gyula Fora (Jira)
• 2024/08/23 [DISCUSS] FLIP-319: Integrating with Kafka’s proper support for 2PC participation (KIP-939). David Radley
• 2024/08/23 RE: [VOTE] FLIP-473: Introduce New SQL Operators Based on Asynchronous State APIs David Radley
• 2024/08/23 [jira] [Created] (FLINK-36144) FlinkSQL upgraded from 1.13.1 to 1.18.1 metrics does not display data mumu (Jira)
• 2024/08/23 [jira] [Created] (FLINK-36143) Sink ES occurred "version conflict" sanqingleo (Jira)
• 2024/08/22 Re: [EXTERNAL] - Re: Discussion on Vertica-Flink Connector Vikas Garg
• 2024/08/22 [jira] [Created] (FLINK-36142) Remove TestTableSourceWithTime and its subclasses to prepare to remove TableEnvironmentInternal#registerTableSourceInternal xuyang (Jira)
• 2024/08/22 [jira] [Created] (FLINK-36141) Set the scanNewlyAddedTableEnabled is true, but does not support automatic identification new table zhongyuandong (Jira)
• 2024/08/22 [jira] [Created] (FLINK-36140) Log a warning when pods are terminated by kubernetes Clara Xiong (Jira)
• 2024/08/22 [jira] [Created] (FLINK-36139) ClassCastException when checkpointing AggregateFunction Vladislav Keda (Jira)
• 2024/08/22 Re: Flink CDC insert-only changelog mode Daniel Henneberger
• 2024/08/22 [jira] [Created] (FLINK-36138) KinesisStreamsSource.buil() should have helpful null errors Jira
• 2024/08/22 [jira] [Created] (FLINK-36137) Missing JarURI leads to null pointer in reconciler Gyula Fora (Jira)
• 2024/08/22 Re: [jira](FLINK-36127) Apply for a jira account and repair bug Leonard Xu
• 2024/08/22 Re: [jira](FLINK-36127) Apply for a jira account and repair bug Yu Chen
• 2024/08/22 [jira](FLINK-36127) Apply for a jira account and repair bug Yunming Tang
• 2024/08/22 Re: [jira](FLINK-35444) Apply for a jira account and repair bug Kaiyuan Zheng
• 2024/08/22 [jira] [Created] (FLINK-36136) Remove TableSource & TableSink impl and utils, docs and etc. xuyang (Jira)
• 2024/08/22 [jira] [Created] (FLINK-36135) Remove the TableSource and TableSink ecosystem APIs like TableFactory, DefinedFieldMapping, FilterableTableSource, etc. xuyang (Jira)
• 2024/08/22 [jira] [Created] (FLINK-36133) Remove subclass implementations of TableSource and TableSink, along with their corresponding Factory classes. xuyang (Jira)
• 2024/08/22 [jira] [Created] (FLINK-36134) Remove the classes associated with TableSource and TableSink as part of the optimization process. xuyang (Jira)
• 2024/08/22 [jira] [Created] (FLINK-36132) Remove codes that references TableSource and TableSink directly at the API level. xuyang (Jira)
• 2024/08/22 Re: [jira](FLINK-35444) Apply for a jira account and repair bug Leonard Xu
• 2024/08/22 [jira] [Created] (FLINK-36131) FlinkSQL upgraded from 1.13.1 to 1.18.1 metrics does not display data mumu (Jira)
• 2024/08/22 [jira] [Created] (FLINK-36130) flink cdc submit yaml task zzm (Jira)
• 2024/08/22 Re: [jira](FLINK-35444) Apply for a jira account and repair bug Gabor Somogyi
• 2024/08/22 [jira](FLINK-35444) Apply for a jira account and repair bug 郑恺原
• 2024/08/22 Issue with table.optimizer.join-reorder-enabled and lookup join Tamas Sule
• 2024/08/21 [jira] [Created] (FLINK-36129) Autoscaler is compatible with Flink 1.20 Rui Fan (Jira)
• 2024/08/21 Re: Flink CDC insert-only changelog mode Hongshun Wang
• 2024/08/21 Re: [VOTE] Apache Flink CDC Release 3.2.0, release candidate #0 Xiqian YU
• 2024/08/21 Re: [VOTE] FLIP-473: Introduce New SQL Operators Based on Asynchronous State APIs Lincoln Lee
• 2024/08/21 Re: [VOTE] FLIP-473: Introduce New SQL Operators Based on Asynchronous State APIs Feng Jin
• 2024/08/21 Re: [VOTE] FLIP-473: Introduce New SQL Operators Based on Asynchronous State APIs Ron Liu
• 2024/08/21 [jira] [Created] (FLINK-36128) Promote LENIENT mode as the default schema evolution behavior yux (Jira)
• 2024/08/21 Flink CDC insert-only changelog mode Daniel Henneberger
• 2024/08/21 Re: [VOTE] FLIP-477: Amazon SQS Source Connector Aleksandr Pilipenko
• 2024/08/21 [jira] [Created] (FLINK-36127) Support sorting watermark on flink web Yu Chen (Jira)
• 2024/08/21 Re: [VOTE] FLIP-477: Amazon SQS Source Connector Ahmed Hamdy
• 2024/08/21 [jira] [Created] (FLINK-36126) Qualification of current catalog and current database should happen during execution, not parsing Sergey Nuyanzin (Jira)
• 2024/08/21 [jira] [Created] (FLINK-36125) File not found exception on restoring state handles with file merging Burak Ozakinci (Jira)
• 2024/08/21 [jira] [Created] (FLINK-36124) S3RecoverableFsDataOutputStream.sync closes the stream and further write operation throw exception Gabor Somogyi (Jira)
• 2024/08/21 [jira] [Created] (FLINK-36123) Add PERCENTILE function Dylan He (Jira)
• 2024/08/21 [jira] [Created] (FLINK-36122) Redundant cast in outer layer when comparing Row Types for equality xuyang (Jira)
• 2024/08/21 [RESULT][VOTE] FLIP-455: Declare async state processing and checkpoint the in-flight requests Zakelly Lan
• 2024/08/21 Re: Re: [VOTE] FLIP-455: Declare async state processing and checkpoint the in-flight requests Zakelly Lan
• 2024/08/21 [jira] [Created] (FLINK-36120) Internal APIs for declaring and defining the record processing Zakelly Lan (Jira)
• 2024/08/21 [jira] [Created] (FLINK-36121) Snapshot the in-flight async state requests Zakelly Lan (Jira)
• 2024/08/21 [jira] [Created] (FLINK-36119) Conditional branchings APIs under `StateFuture` Zakelly Lan (Jira)
• 2024/08/21 [jira] [Created] (FLINK-36118) FLIP-455: Declare async state processing and checkpoint the in-flight requests Zakelly Lan (Jira)
• 2024/08/21 [jira] [Created] (FLINK-36117) Implement AsyncKeyedStateBackend for RocksDBKeyedStateBackend and HeapKeyedStateBackend. wang qian (Jira)
• 2024/08/21 Re: Re: [VOTE] FLIP-455: Declare async state processing and checkpoint the in-flight requests Yuan Mei
• 2024/08/21 [VOTE] FLIP-477: Amazon SQS Source Connector Abhisagar Khatri
• 2024/08/21 [jira] [Created] (FLINK-36116) Javadocs aren't visible anymore for Flink 1.17 and above Martijn Visser (Jira)
• 2024/08/20 Re: Re: [VOTE] FLIP-455: Declare async state processing and checkpoint the in-flight requests Zakelly Lan
• 2024/08/20 Re: [VOTE] FLIP-473: Introduce New SQL Operators Based on Asynchronous State APIs Zakelly Lan
• 2024/08/20 [VOTE] FLIP-473: Introduce New SQL Operators Based on Asynchronous State APIs Xuyang
• 2024/08/20 [jira] [Created] (FLINK-36115) Allow to scan newly table DDL during incremental reading stage. LvYanquan (Jira)
• 2024/08/20 [jira] [Created] (FLINK-36114) Schema registry should block when handling existing requests yux (Jira)
• 2024/08/20 [jira] [Created] (FLINK-36113) Condition 'transform instanceof PhysicalTransformation' is always 'false' tiancx (Jira)
• 2024/08/20 [jira] [Created] (FLINK-36112) Add Support for CreateFlag.NO_LOCAL_WRITE in FLINK on YARN's File Creation to Manage Disk Space and Network Load in Labeled YARN Nodes liang yu (Jira)
• 2024/08/20 [jira] [Created] (FLINK-36111) fix: adjust MultiTableCommittableChannelComputer Topology name MOBIN (Jira)
• 2024/08/20 Re: [DISCUSS] FLIP-XXX Amazon SQS Source Connector Ahmed Hamdy
• 2024/08/20 [jira] [Created] (FLINK-36110) Periodic save points trigger continuously Gyula Fora (Jira)
• 2024/08/20 [jira] [Created] (FLINK-36109) Improve FlinkStateSnapshot resource labels for efficient filtering Gyula Fora (Jira)
• 2024/08/20 [jira] [Created] (FLINK-36108) Wait for state download on cancellation to enforce cleanup Piotr Nowojski (Jira)
• 2024/08/19 [jira] [Created] (FLINK-36107) schema event support custom callback melin (Jira)
• 2024/08/19 [jira] [Created] (FLINK-36106) t_flink_autoscaler_event_handler is not cleaned after each testing Rui Fan (Jira)
• 2024/08/19 [jira] [Created] (FLINK-36105) CDC pipeline job could not restore from state in Flink 1.20 yux (Jira)
• 2024/08/19 [jira] [Created] (FLINK-36104) flink 1.20 not suport logback xuhaiLong (Jira)
• 2024/08/19 Re: [VOTE] Apache Flink CDC Release 3.2.0, release candidate #0 Xiqian YU
• 2024/08/19 [jira] [Created] (FLINK-36103) Support ESCAPE in built-in function LIKE formally Dylan He (Jira)
• 2024/08/19 [jira] [Created] (FLINK-36102) Support ESCAPE in built-in function LIKE formally Dylan He (Jira)
• 2024/08/19 [jira] [Created] (FLINK-36101) Support ESCAPE in built-in function LIKE formally Dylan He (Jira)
• 2024/08/19 [jira] [Created] (FLINK-36100) Support ESCAPE in built-in function LIKE formally Dylan He (Jira)
• 2024/08/19 [FLINK-35177] Fix DataGen Connector documentation Sergei Morozov
• 2024/08/19 [jira] [Created] (FLINK-36099) JobIDLoggingITCase fails due to "Cannot find task to fail for execution [...]" info log message in TM logs Matthias Pohl (Jira)
• 2024/08/19 [jira] [Created] (FLINK-36098) Add support for Table Comments in Flink SQL ALTER TABLE statements Steffen Hoellinger (Jira)
• 2024/08/19 [jira] [Created] (FLINK-36097) Add timeseries support for SampleSplitter Jiabao Sun (Jira)
• 2024/08/19 Re:Re: Re:Re: Re: Re:Re: [DISCUSS] FLIP-473: Introduce New SQL Operators Based on Asynchronous State APIs Xuyang
• 2024/08/19 [jira] [Created] (FLINK-36096) Support sync interface in state v2 api. wang qian (Jira)
• 2024/08/19 Re: [ANNOUNCE] New Apache Flink Committer - Xuannan Su Xuannan Su
• 2024/08/19 [jira] [Created] (FLINK-36095) KeyedLookupJoinWrapper should shuffle by input upsertKey instead of join key to avoid changelog disordering lincoln lee (Jira)
• 2024/08/19 [jira] [Created] (FLINK-36094) CDC SchemaRegistryRequestHandler should throw exception which is not SchemaEvolveException Hongshun Wang (Jira)
• 2024/08/19 [jira] [Created] (FLINK-36093) PreTransform operator wrongly filters out columns when multiple transform rules were defined yux (Jira)
• 2024/08/19 Re: [DISCUSS] FLIP-475: Support Adaptive Skewed Join Optimization. Zhu Zhu
• 2024/08/19 [jira] [Created] (FLINK-36092) Transform doesn't fully support with schema evolution yux (Jira)
• 2024/08/18 Re: [DISCUSS] FLIP-474: Store operator name and UID in state metadata Gabor Somogyi
• 2024/08/18 [jira] [Created] (FLINK-36091) Config passed in via the environment variable FLINK_PROPERTIES which has space not getting processed lajith (Jira)
• 2024/08/18 [jira] [Created] (FLINK-36090) Bug with IngestDB restore operation for priority queue state in backend Maxim Vershinin (Jira)
• 2024/08/18 Re: [VOTE] Apache Flink CDC Release 3.2.0, release candidate #0 Qingsheng Ren
• 2024/08/18 [jira] [Created] (FLINK-36089) clean codegen print function Jacky Lau (Jira)
• 2024/08/18 Re: [VOTE] Apache Flink CDC Release 3.2.0, release candidate #0 Leonard Xu
• 2024/08/18 Re: [VOTE] Apache Flink CDC Release 3.2.0, release candidate #0 Yanquan Lv
• 2024/08/18 Re: Re:Re: Re: Re:Re: [DISCUSS] FLIP-473: Introduce New SQL Operators Based on Asynchronous State APIs ron
• 2024/08/18 [jira] [Created] (FLINK-36088) Fix NopointException in PaimonDataSink. LvYanquan (Jira)
• 2024/08/18 [jira] [Created] (FLINK-36087) Fix LvYanquan (Jira)
• 2024/08/18 Re: [ANNOUNCE] New Apache Flink Committer - Xuannan Su Jiabao Sun
• 2024/08/18 Re: [ANNOUNCE] New Apache Flink Committer - Xuannan Su Guowei Ma
• 2024/08/18 Re: [ANNOUNCE] New Apache Flink Committer - Xuannan Su Luke Chen
• 2024/08/18 [jira] [Created] (FLINK-36086) SQL Server source connector skips changes if restarted mid transaction Sergei Morozov (Jira)
• 2024/08/18 [jira] [Created] (FLINK-36085) Refeactor operation with LIKE/ILIKE Sergey Nuyanzin (Jira)
• 2024/08/18 [jira] [Created] (FLINK-36084) Optimze parquet binary getBytes with getBytesUnsafe to avoid copy cost xy (Jira)
• 2024/08/18 Re: [ANNOUNCE] New Apache Flink Committer - Xuannan Su Aleksandr Pilipenko
• 2024/08/18 Re: [VOTE] Apache Flink CDC Release 3.2.0, release candidate #0 Yanquan Lv
• 2024/08/18 Re: [ANNOUNCE] New Apache Flink Committer - Xuannan Su Junrui Lee
• 2024/08/18 Re: [ANNOUNCE] New Apache Flink Committer - Xuannan Su Feng Jin
• 2024/08/18 [jira] [Created] (FLINK-36083) Fix kafka table api doc's Connector Options table broken Zhongqiang Gong (Jira)
• 2024/08/18 Re: [ANNOUNCE] New Apache Flink Committer - Xuannan Su Rui Fan
• 2024/08/17 Re: [ANNOUNCE] New Apache Flink Committer - Xuannan Su Leonard Xu
• 2024/08/17 Re: [ANNOUNCE] New Apache Flink Committer - Xuannan Su gongzhongqiang
• 2024/08/17 [jira] [Created] (FLINK-36082) Fix NotSerializableException for KafkaDataSink LvYanquan (Jira)
• 2024/08/17 Re: [ANNOUNCE] New Apache Flink Committer - Xuannan Su Yanquan Lv
• 2024/08/17 [jira] [Created] (FLINK-36081) Flink CDC MySQL source connector missing some columns data of newly added tables Mingya Wang (Jira)
• 2024/08/17 Re: [ANNOUNCE] New Apache Flink Committer - Xuannan Su Hong
• 2024/08/17 Re: [ANNOUNCE] New Apache Flink Committer - Xuannan Su Samrat Deb
• 2024/08/17 Re: [ANNOUNCE] New Apache Flink Committer - Xuannan Su Qingsheng Ren
• 2024/08/17 Re: [ANNOUNCE] New Apache Flink Committer - Xuannan Su Zakelly Lan
• 2024/08/17 [ANNOUNCE] New Apache Flink Committer - Xuannan Su Xintong Song
• 2024/08/17 [jira] [Created] (FLINK-36080) Add SQL Connector for SQS Ahmed Hamdy (Jira)
• 2024/08/17 [jira] [Created] (FLINK-36079) Add Documentation for SQS Table API connector Ahmed Hamdy (Jira)
• 2024/08/16 [jira] [Created] (FLINK-36078) Add Documentation for PubSubSink Table API connector Ahmed Hamdy (Jira)
• 2024/08/16 [jira] [Created] (FLINK-36077) Implement Table API support for PubSubSink V2 Ahmed Hamdy (Jira)
• 2024/08/16 [jira] [Created] (FLINK-36076) Hotfix: Set isSchemaChangeApplying as isSchemaChangeApplying for thread safe. Hongshun Wang (Jira)
• 2024/08/15 [jira] [Created] (FLINK-36075) Add paginate partition strategy for mongodb connector Jiabao Sun (Jira)
• 2024/08/15 [jira] [Created] (FLINK-36074) Supprt insert overwrite semantics for mongodb table sink. Jiabao Sun (Jira)
• 2024/08/15 [DISCUSS] FLIP-475: Support Adaptive Skewed Join Optimization. Lei Yang
• 2024/08/15 SinkV2 framework operators Rodrigo Meneses
• 2024/08/15 [jira] [Created] (FLINK-36073) ApplicationMode with the K8s operator does not support downloading jars via filesystem plugins Robert Metzger (Jira)
• 2024/08/15 Re: Re: [VOTE] FLIP-455: Declare async state processing and checkpoint the in-flight requests Hangxiang Yu
• 2024/08/15 Re: Re: [VOTE] FLIP-455: Declare async state processing and checkpoint the in-flight requests Ahmed Hamdy
• 2024/08/15 [jira] [Created] (FLINK-36072) Optimizing the Overhead of the Network Layer in Adaptive Execution Scenarios Junrui Li (Jira)
• 2024/08/15 [jira] [Created] (FLINK-36071) Using System.nanoTime to measure the elapsed time instead of System.currentTimeMillis Rui Fan (Jira)
• 2024/08/15 [jira] [Created] (FLINK-36070) Modifying web UI to adapt to Incremental JobGraph Generation Junrui Li (Jira)
• 2024/08/15 [jira] [Created] (FLINK-36069) Extending job detail rest API to adapt to Incremental JobGraph Generation Junrui Li (Jira)
• 2024/08/15 [jira] [Created] (FLINK-36068) Support for adaptive job scheduling based on StreamGraph Junrui Li (Jira)
• 2024/08/15 [jira] [Created] (FLINK-36067) Introducing the StreamGraphOptimizer component Junrui Li (Jira)
• 2024/08/15 [jira] [Created] (FLINK-36066) Introducing the AdaptiveGraphGenerator component Junrui Li (Jira)
• 2024/08/15 [jira] [Created] (FLINK-36065) Support for submitting StreamGraph Junrui Li (Jira)
• 2024/08/15 [jira] [Created] (FLINK-36064) Refactor CollectResultIterator to eliminate dependency on OperatorID Junrui Li (Jira)
• 2024/08/15 [jira] [Created] (FLINK-36063) Migrate StreamGraph and its related classes to flink-runtime Junrui Li (Jira)
• 2024/08/15 [jira] [Created] (FLINK-36062) Only the first one in the delayed data will trigger,and it will only be restored when the transition is made to the current day window Darren_Han (Jira)
• 2024/08/15 [VOTE] Apache Flink CDC Release 3.2.0, release candidate #0 Qingsheng Ren
• 2024/08/14 [jira] [Created] (FLINK-36061) Support Apache iceberg for pipeline connector ZhengYu Chen (Jira)
• 2024/08/14 [RESULT][VOTE] FLIP-470: Support Adaptive Broadcast Join Xia Sun
• 2024/08/14 [jira] [Created] (FLINK-36060) Transform built-in functions could not handle NULL values as arguments yux (Jira)
• 2024/08/14 [jira] [Created] (FLINK-36059) SqlClientITCase failed due to could not create/start container Weijie Guo (Jira)
• 2024/08/14 [jira] [Created] (FLINK-36058) OperatorTestHarness is always using checkpointId=0 for state recovery Rodrigo Meneses (Jira)
• 2024/08/14 RE: [DISCUSS] FLIP-XXX Apicurio-avro format David Radley
• 2024/08/14 Re: [DISCUSS] CLI action deprecation process Ferenc Csaky
• 2024/08/14 [SUMMARY] Flink 2.0 Release Sync 08/14/2024 Xintong Song
• 2024/08/14 Re: [VOTE] FLIP-470: Support Adaptive Broadcast Join Ron Liu
• 2024/08/14 [jira] [Created] (FLINK-36057) Allow specifying ARN for AWS connector resources Elphas Toringepi (Jira)
• 2024/08/14 Re:Re: Re: Re:Re: [DISCUSS] FLIP-473: Introduce New SQL Operators Based on Asynchronous State APIs Xuyang
• 2024/08/14 [jira] [Created] (FLINK-36056) change flink.connector.elasticsearch.version to a release version in branch release-3.2 wuzexian (Jira)
• 2024/08/13 [jira] [Created] (FLINK-36055) Change flink.connector.elasticsearch.version to a release version wuzexian (Jira)
• 2024/08/13 Re:Re: [VOTE] FLIP-455: Declare async state processing and checkpoint the in-flight requests Xuyang
• 2024/08/13 [jira] [Created] (FLINK-36054) Cleanup Flink CDC pom and release scripts Qingsheng Ren (Jira)
• 2024/08/13 [jira] [Created] (FLINK-36053) Support multi-version integration test in mongodb connector Jiabao Sun (Jira)
• 2024/08/13 Re: [VOTE] FLIP-455: Declare async state processing and checkpoint the in-flight requests Yuepeng Pan
• 2024/08/13 [jira] [Created] (FLINK-36052) add elasticsearch.md for elasticsearch pipeline connector wuzexian (Jira)
• 2024/08/13 Re: [VOTE] FLIP-455: Declare async state processing and checkpoint the in-flight requests Yanfei Lei
• 2024/08/13 [jira] [Created] (FLINK-36051) JDBC sink doesn't re-prepare invalidated prepared statements Sergei Morozov (Jira)
• 2024/08/13 [jira] [Created] (FLINK-36049) Add CompiledPlan annotations to BatchExecSortLimit Jim Hughes (Jira)
• 2024/08/13 [jira] [Created] (FLINK-36048) Add CompiledPlan annotations to BatchExecRank Jim Hughes (Jira)
• 2024/08/13 [jira] [Created] (FLINK-36047) Add CompiledPlan annotations to BatchExecOverAggregate Jim Hughes (Jira)
• 2024/08/13 [jira] [Created] (FLINK-36046) Change the existing org.apache.flink.streaming.api.functions.sink#DiscardingSink and org.apache.flink.streaming.api.functions.sink#PrintSinkFunction to use the new interfaces Min Zhao (Jira)
• 2024/08/13 [jira] [Created] (FLINK-36045) Add support for SharePlex JSON format to Flink Formats. Will-Hyde (Jira)
• 2024/08/13 Re: [ANNOUNCE] Flink CDC release-3.2 branch cut Leonard Xu
• 2024/08/13 [jira] [Created] (FLINK-36044) In Flinkcdc-connect-mysql2.4 version, scan.snapshot.fetch.size does not take effect zhanghuaibei (Jira)
• 2024/08/13 Re: Re: Re:Re: [DISCUSS] FLIP-473: Introduce New SQL Operators Based on Asynchronous State APIs Feng Jin
• 2024/08/13 [jira] [Created] (FLINK-36043) [SQL] Unexpected SinkMaterializer operator generated when use coalesce function on upsert key fields Yuan Kui (Jira)
• 2024/08/13 Re: [DISCUSS] FLIP-XXX Amazon SQS Source Connector Saurabh Singh
• 2024/08/12 Re: [ANNOUNCE] Flink CDC release-3.2 branch cut Qingsheng Ren
• 2024/08/12 Re: [ANNOUNCE] Flink CDC release-3.2 branch cut Leonard Xu
• 2024/08/12 [VOTE] FLIP-455: Declare async state processing and checkpoint the in-flight requests Zakelly Lan
• 2024/08/12 [jira] [Created] (FLINK-36042) newly added tables capture xuhaiLong (Jira)
• 2024/08/12 [jira] [Created] (FLINK-36041) Eliminate Calcite dependency during runtime yux (Jira)
• 2024/08/12 [jira] [Created] (FLINK-36040) mysql cdc pipeline recover error from ck xuhaiLong (Jira)
• 2024/08/12 [jira] [Created] (FLINK-36039) Support clean historical event handler records in autoscaler jdbc plugin RocMarshal (Jira)
• 2024/08/12 [jira] [Created] (FLINK-36038) SHOW CREATE VIEW returns invalid query Sergey Nuyanzin (Jira)
• 2024/08/12 [jira] [Created] (FLINK-36037) Add compability for 1.9 last savepoint info on upgrade/recovery Mate Czagany (Jira)
• 2024/08/12 [ANNOUNCE] Flink CDC release-3.2 branch cut Qingsheng Ren
• 2024/08/12 Re: [DISCUSS] Flink 2.0 Release Plan Xintong Song
• 2024/08/12 [jira] [Created] (FLINK-36036) CDC remove unused dependency jar from calcite-core Hongshun Wang (Jira)
• 2024/08/12 Re: [DISCUSS] re-open FLINK-28842 Add client.id.prefix for the KafkaSink Ahmed Hamdy
• 2024/08/11 [jira] [Created] (FLINK-36035) Remove zipped dependency files from flink-python Grace Grimwood (Jira)
• 2024/08/11 Re: [VOTE] FLIP-470: Support Adaptive Broadcast Join Zhu Zhu
• 2024/08/11 Re: [VOTE] FLIP-470: Support Adaptive Broadcast Join Lincoln Lee
• 2024/08/11 [jira] [Created] (FLINK-36034) Remove dependencies of Flink table planner in Transform module yux (Jira)
• 2024/08/11 Re:Re: Re:Re: [DISCUSS] FLIP-473: Introduce New SQL Operators Based on Asynchronous State APIs Xuyang
• 2024/08/11 [jira] [Created] (FLINK-36033) FLIP-469: Supports Adaptive Optimization of StreamGraph Junrui Li (Jira)
• 2024/08/11 [jira] [Created] (FLINK-36032) FLIP-468: Introducing StreamGraph-Based Job Submission Junrui Li (Jira)
• 2024/08/11 [VOTE] FLIP-470: Support Adaptive Broadcast Join Xia Sun
• 2024/08/11 [jira] [Created] (FLINK-36031) Migrate kubernetes operator metrics from OKHttp Interceptor API to Fabric8 Interceptor API Sam Barker (Jira)
• 2024/08/11 [jira] [Created] (FLINK-36030) Don't use negative values for changelog recovery tests Roman Khachatryan (Jira)
• 2024/08/10 [jira] [Created] (FLINK-36029) Add @Nullable Annotation to ValueState's Value Method Return Type LEE SOMANG (Jira)

• Later messages