dev  

Messages by Date

• 2026/04/04 RE: HTTP connector David Radley
• 2026/04/04 Re: HTTP connector Pedro Mázala
• 2026/04/03 Re: HTTP connector David Anderson
• 2026/04/03 [jira] [Created] (FLINK-39400) Fix multiple documentation bugs in English and Chinese docs Aleksandr Savonin (Jira)
• 2026/04/03 [Discuss] FLIP-314: Behavioral Expectation of JobStatusChangedListener Instantiation in Application Mode Swapna Marru
• 2026/04/03 [jira] [Created] (FLINK-39399) Integer overflow in HyperLogLogPlusPlus.query() causes APPROX_COUNT_DISTINCT undercount at high cardinality Jim Hughes (Jira)
• 2026/04/03 Re: HTTP connector Pedro Mázala
• 2026/04/03 [jira] [Created] (FLINK-39398) Handle duplicate key errors in MongoWriter bulk write retry loop Aleksandr Savonin (Jira)
• 2026/04/03 [jira] [Created] (FLINK-39397) postgres pk table encounted an error when delete a record Tao Wang (Jira)
• 2026/04/03 [jira] [Created] (FLINK-39396) Simplify early return condition in SqlLikeChainChecker.check() Qilong Wang (Jira)
• 2026/04/03 [FLINK-31942] Looking for review — Conditional Writes in DynamoDB connector Tomasz Kaczmarek
• 2026/04/02 [jira] [Created] (FLINK-39395) Add spotless upToDateChecking Sergey Nuyanzin (Jira)
• 2026/04/02 [jira] [Created] (FLINK-39394) Job overview metrics (business/backpressure/data skew) are showing N/A when some nodes are finished Aleksandr Iushmanov (Jira)
• 2026/04/02 [jira] [Created] (FLINK-39393) Add StartMode tableChange Sergey Nuyanzin (Jira)
• 2026/04/02 [jira] [Created] (FLINK-39392) Support conditional traits for PTFs Gustavo de Morais (Jira)
• 2026/04/02 [ANNOUNCE] Apache Auron (Incubating) Flink kafka source is now available Mang Zhang
• 2026/04/02 [jira] [Created] (FLINK-39391) scan.snapshot.fetch.size is not propagated to Debezium properties in Oracle/SqlServer/DB2/Postgres connectors, causing severe snapshot performance degradation tianfy (Jira)
• 2026/04/02 [jira] [Created] (FLINK-39390) Add Extensibility to Autoscaler Components via the Plugin Mechanism Dennis-Mircea Ciupitu (Jira)
• 2026/04/02 HTTP connector David Radley
• 2026/04/02 [jira] [Created] (FLINK-39389) Investigate updating the Apache HTTP connector to support java 8. David Radley (Jira)
• 2026/04/01 [jira] [Created] (FLINK-39388) Fix Flaky DataGeneratorSourceITCase#testGatedRateLimiter featzhang (Jira)
• 2026/04/01 [jira] [Created] (FLINK-39387) Fix flaky scheduler benchmark tests caused by thread assertion failure in async TDD creation Liu (Jira)
• 2026/04/01 [jira] [Created] (FLINK-39386) For Flink 2.x+, support limit the rate at the source peiyu (Jira)
• 2026/04/01 Re: [DISCUSS] Include observedGeneration for Suspended Flink Deployments Sergio Chong Loo
• 2026/04/01 [jira] [Created] (FLINK-39385) Timestampdiff for time fails with scala.MatchError: (TIME_WITHOUT_TIME_ZONE,TIME_WITHOUT_TIME_ZONE) (of class scala.Tuple2) Sergey Nuyanzin (Jira)
• 2026/04/01 Re: FLIP-504: Blue/Green Deployments for Flink on Kubernetes - Phase 2 (WIP/Draft PR) Sergio Chong Loo
• 2026/04/01 Re: Re: [VOTE] FLIP-568: Strict BYTES-to-STRING CAST with UTF-8 Validation Utilities Aleksandr Savonin
• 2026/04/01 [jira] [Created] (FLINK-39384) PyFlink load_plan() CompiledPlans cannot be executed Chris MacGregor (Jira)
• 2026/04/01 RE: Re: [VOTE] FLIP-568: Strict BYTES-to-STRING CAST with UTF-8 Validation Utilities David Radley
• 2026/04/01 Re: FLIP-504: Blue/Green Deployments for Flink on Kubernetes - Phase 2 (WIP/Draft PR) Daniel Rossos via dev
• 2026/04/01 Re: Re: [VOTE] FLIP-568: Strict BYTES-to-STRING CAST with UTF-8 Validation Utilities Ferenc Csaky
• 2026/04/01 Re: Re: [VOTE] FLIP-568: Strict BYTES-to-STRING CAST with UTF-8 Validation Utilities Sergey Nuyanzin
• 2026/04/01 [jira] [Created] (FLINK-39383) [Docs] Improve scan.incremental.snapshot.chunk.key-column documentation for MySQL/PostgreSQL/Oracle/DB2/SQLServer connectors ericzeng (Jira)
• 2026/04/01 [jira] [Created] (FLINK-39382) [Docs][Kafka] Clarify properties.auto.offset.reset support in SQL connector Kumar Mallikarjuna (Jira)
• 2026/04/01 [jira] [Created] (FLINK-39381) Add user facing documentation for ProcessTableFunctionTestHarness Mika Naylor (Jira)
• 2026/04/01 [jira] [Created] (FLINK-39380) Add support for test snapshotting/restoration to ProcessTableFunctionTestHarness Mika Naylor (Jira)
• 2026/04/01 [jira] [Created] (FLINK-39379) Add support for state in ProcessTableFunctionTestHarness Mika Naylor (Jira)
• 2026/04/01 [jira] [Created] (FLINK-39378) Add support for timers in ProcessTableFunctionTestHarness Mika Naylor (Jira)
• 2026/04/01 [jira] [Created] (FLINK-39377) Initial ProcessTableFunctionTestHarness implementation Mika Naylor (Jira)
• 2026/04/01 [jira] [Created] (FLINK-39376) Show TaskManager IP address in Checkpoint Subtask Statistics jingzi (Jira)
• 2026/04/01 [jira] [Created] (FLINK-39375) Add explicit serialVersionUID to WatermarkAlignmentParams Liu (Jira)
• 2026/04/01 [jira] [Created] (FLINK-39374) Rename KuduWriterConfig.maxBufferSize to maxMutationBufferOps Marton Greber (Jira)
• 2026/04/01 Re: Re: [VOTE] FLIP-568: Strict BYTES-to-STRING CAST with UTF-8 Validation Utilities Martijn Visser
• 2026/03/31 [jira] [Created] (FLINK-39373) An error occurred when modifying the default value of a column while executing the StarRocks Pipeline Sink operation Yanquan Lv (Jira)
• 2026/03/31 [jira] [Created] (FLINK-39372) Potential MySQL Binlog offset comparison failure after mysql-bin.999999 Xiqian Yu (Jira)
• 2026/03/31 Re:Re: [VOTE] FLIP-568: Strict BYTES-to-STRING CAST with UTF-8 Validation Utilities Xuyang
• 2026/03/31 [jira] [Created] (FLINK-39371) CurrentDatabase fails for some patterns Sergey Nuyanzin (Jira)
• 2026/03/31 [jira] [Created] (FLINK-39370) In-place scaling check only inspects K8s resource spec for adaptive scheduler, ignoring JM running configuration Dennis-Mircea Ciupitu (Jira)
• 2026/03/31 [jira] [Created] (FLINK-39369) ChangelogNormalize Operator In WAL Image Mode with Fluss Giannis Polyzos (Jira)
• 2026/03/31 Re: [DISCUSS] FLIP-572: Introduce Flink-Kafka Transactions Management Tool Aleksandr Savonin
• 2026/03/31 [jira] [Created] (FLINK-39368) [connector-http] Add User-Agent configuration support for HTTP sink and lookup featzhang (Jira)
• 2026/03/31 [jira] [Created] (FLINK-39367) [connector-http] Add configurable error logging with detailed context featzhang (Jira)
• 2026/03/31 [jira] [Created] (FLINK-39366) [connector-http] Add retry support with exponential backoff for HTTP Sink featzhang (Jira)
• 2026/03/31 [jira] [Created] (FLINK-39365) [CONNECTOR-HTTP] 支持自定义 HTTP HEADERS VIA CONFIGOPTION featzhang (Jira)
• 2026/03/31 [jira] [Created] (FLINK-39364) [CONNECTOR-HTTP] Add request timeout as typed ConfigOption for HTTP lookup source and sink featzhang (Jira)
• 2026/03/31 [jira] [Created] (FLINK-39363) [Flaky Tests] PaimonSinkITCase.testDuplicateCommitAfterRestore Yanquan Lv (Jira)
• 2026/03/31 [jira] [Created] (FLINK-39362) [Docs] Fix broken/outdated connector download links and improve link maintenance strategy Yanquan Lv (Jira)
• 2026/03/30 [DISCUSS][FLINK-38697] TaskInformation blobs accumulate without cleanup causing storage exhaustion - request for review Piotr Rudnicki
• 2026/03/30 [jira] [Created] (FLINK-39361) [connector-http] Add Quick Start section to Table/SQL HTTP connector documentation featzhang (Jira)
• 2026/03/30 [jira] [Created] (FLINK-39360) Like clause doesn't support some patterns Timo Walther (Jira)
• 2026/03/30 Re: FLIP-504: Blue/Green Deployments for Flink on Kubernetes - Phase 2 (WIP/Draft PR) Sergio Chong Loo
• 2026/03/30 Re: [ANNOUNCE] Apache Flink CDC 3.6.0 released Leonard Xu
• 2026/03/30 [jira] [Created] (FLINK-39359) Introduce a mechanism to ensure that the generated documentation stays consistent with the code. Yuepeng Pan (Jira)
• 2026/03/30 Re: [DISCUSS] FLIP-572: Introduce Flink-Kafka Transactions Management Tool Hongshun Wang
• 2026/03/30 [jira] [Created] (FLINK-39358) Constraint and watermark should stay while CoA MT if there is no explicit change with schema or contraint definition Sergey Nuyanzin (Jira)
• 2026/03/30 [jira] [Created] (FLINK-39357) FLIP-567: Introduce a ProcessTableFunction Test Harness Mika Naylor (Jira)
• 2026/03/30 [jira] [Created] (FLINK-39356) FlinkStateSnapshot cleanup fails with NPE when status is null, permanently blocking CR and namespace deletion Yanis Djeridi (Jira)
• 2026/03/30 Re: [VOTE] FLIP-568: Strict BYTES-to-STRING CAST with UTF-8 Validation Utilities Ramin Gharib
• 2026/03/30 Re: [VOTE] FLIP-568: Strict BYTES-to-STRING CAST with UTF-8 Validation Utilities Timo Walther
• 2026/03/30 [jira] [Created] (FLINK-39355) Table program cannot be compiled for JSON_OBJECT Timo Walther (Jira)
• 2026/03/30 [VOTE] FLIP-568: Strict BYTES-to-STRING CAST with UTF-8 Validation Utilities Gustavo de Morais
• 2026/03/30 Re: Re: Re: [DISCUSS] FLIP-568: Strict BYTES-to-STRING CAST with UTF-8 Validation Utilities Gustavo de Morais
• 2026/03/30 Re: [DISCUSS] FLIP-572: Introduce Flink-Kafka Transactions Management Tool Aleksandr Savonin
• 2026/03/30 Re: [DISCUSS] FLIP-569: Sunset the Stateful Functions (StateFun) Sub-project Jacky Lau
• 2026/03/30 Re: [DISCUSS] FLIP-572: Introduce Flink-Kafka Transactions Management Tool Aleksandr Savonin
• 2026/03/30 [jira] [Created] (FLINK-39354) SchemaUtils.applyAddColumnEvent fails when referenced existing column name differs only by case lllmao (Jira)
• 2026/03/30 [jira] [Created] (FLINK-39353) Dark mode text is nearly unreadable after recent Flink website rebuild Rui Fan (Jira)
• 2026/03/30 Re: FLIP-556 wiki edit permission question Ramin Gharib
• 2026/03/30 Re: [DISCUSS] FLIP-569: Sunset the Stateful Functions (StateFun) Sub-project Ramin Gharib
• 2026/03/30 [jira] [Created] (FLINK-39352) Document START_MODE behavior Ramin Gharib (Jira)
• 2026/03/30 [jira] [Created] (FLINK-39351) [Flaky Tests] NewlyAddedTableITCase.testJobManagerFailoverForNewlyAddedTableWithAheadBinlog Yanquan Lv (Jira)
• 2026/03/29 [jira] [Created] (FLINK-39350) [Flaky Tests] MySqlToPaimonE2eITCase.testSinkToAppendOnlyTable Yanquan Lv (Jira)
• 2026/03/29 [ANNOUNCE] Apache Flink CDC 3.6.0 released Yanquan Lv
• 2026/03/29 Re: [DISCUSS] FLIP-572: Introduce Flink-Kafka Transactions Management Tool Hongshun Wang
• 2026/03/29 [jira] [Created] (FLINK-39349) Support TO_CHANGELOG retract/upsert stream to upsert stream with deletion flag (4.2.2.1) Gustavo de Morais (Jira)
• 2026/03/28 [RESULT][VOTE] Apache Flink CDC Release 3.6.0, release candidate #2 Yanquan Lv
• 2026/03/28 Re: [VOTE] Apache Flink CDC Release 3.6.0, release candidate #2 Yanquan Lv
• 2026/03/28 [jira] [Created] (FLINK-39348) Add Interval to reuse code for freshness and start mode Sergey Nuyanzin (Jira)
• 2026/03/28 Re: [jira] [Created] (FLINK-39346) Improve the error message when the AddColumnEvent fails 陈 小健
• 2026/03/28 Re: [jira] [Created] (FLINK-39347) Flink otel reporter doesnt report any metrics 陈 小健
• 2026/03/28 Re: [DISCUSS] FLIP-572: Introduce Flink-Kafka Transactions Management Tool Shekhar Rajak
• 2026/03/27 [jira] [Created] (FLINK-39347) Flink otel reporter doesnt report any metrics Sujit Joshi (Jira)
• 2026/03/27 [jira] [Created] (FLINK-39346) Improve the error message when the AddColumnEvent fails peiyu (Jira)
• 2026/03/27 [RESULT][VOTE] FLIP-567: Introduce a ProcessTableFunction Test Harness Mika Naylor
• 2026/03/27 Re: [VOTE] FLIP-567: Introduce a ProcessTableFunction Test Harness Mika Naylor
• 2026/03/27 Re: [VOTE] FLIP-567: Introduce a ProcessTableFunction Test Harness Samrat Deb
• 2026/03/27 RE: [VOTE] FLIP-567: Introduce a ProcessTableFunction Test Harness David Radley
• 2026/03/27 [jira] [Created] (FLINK-39345) Support SELECT * EXCLUDE(columns) syntax in Flink SQL Gustavo de Morais (Jira)
• 2026/03/27 [jira] [Created] (FLINK-39344) [Doc] Fix inconsistencies between MySqlDataSourceOptions and MySQL Pipeline Connector documentation XiaodongHuan (Jira)
• 2026/03/27 [DISCUSS][FLINK-39151] Hide warning about UnixOperatingSystemMXBean missing on Windows - request for review Piotr Przybylski
• 2026/03/27 [jira] [Created] (FLINK-39343) Fix inconsistencies in sql_function documentation Ramin Gharib (Jira)
• 2026/03/27 Re: [DISCUSS] FLIP-567: Introduce a ProcessTableFunction Test Harness Mika Naylor
• 2026/03/27 [jira] [Created] (FLINK-39342) [Iceberg] Support hadoop.conf.* prefix to pass Hadoop configuration properties ericzeng (Jira)
• 2026/03/27 [jira] [Created] (FLINK-39341) Implement DatabaseMetaData methods for DBeaver compatibility Navis Ryu (Jira)
• 2026/03/26 [jira] [Created] (FLINK-39340) Transform binary multi join back to regular join Dmitriy Linevich (Jira)
• 2026/03/26 Re: [VOTE] Apache Flink CDC Release 3.6.0, release candidate #2 Lincoln Lee
• 2026/03/26 Re: [VOTE] Apache Flink CDC Release 3.6.0, release candidate #2 Hongshun Wang
• 2026/03/26 [jira] [Created] (FLINK-39339) Consider immutable cols to infer sink required updated mode traits Xuyang Zhong (Jira)
• 2026/03/26 [SUMMARY] Flink 2.3 release sync -- reviews needed for flaky test PRs David Anderson
• 2026/03/26 [DISCUSS] extending the feature freeze date of Flink 2.3 David Anderson
• 2026/03/26 [jira] [Created] (FLINK-39338) Fix topic collision in parameterized KafkaWriter tests Aleksandr Savonin (Jira)
• 2026/03/26 [jira] [Created] (FLINK-39336) Clean up code in the `flink-cdc-pipeline-connector-kafka` module that is compatible with older versions of Flink. peiyu (Jira)
• 2026/03/26 [jira] [Created] (FLINK-39337) Clean up the compatibility code for Flink 1.19 in the `e2e-tests` module. peiyu (Jira)
• 2026/03/26 [jira] [Created] (FLINK-39335) Upgrade `flink-connector-starrocks` to no longer require compatibility with Flink 1.19. peiyu (Jira)
• 2026/03/26 Re: FLIP-504: Blue/Green Deployments for Flink on Kubernetes - Phase 2 (WIP/Draft PR) Ryan van Huuksloot via dev
• 2026/03/26 Re: [VOTE] Apache Flink CDC Release 3.6.0, release candidate #2 Xiqian YU
• 2026/03/26 [jira] [Created] (FLINK-39334) flink-connector-mongodb fails when write concern is set to zero Jacob Jona Fahlenkamp (Jira)
• 2026/03/26 [jira] [Created] (FLINK-39333) Introduce an alias config option for query-params to allow an alternative key to the column name to be used as the query param key. David Radley (Jira)
• 2026/03/26 [jira] [Created] (FLINK-39332) Ensure body-template error messages associated with exceptions are in the log. David Radley (Jira)
• 2026/03/26 [jira] [Created] (FLINK-39331) Add Experimental Annotations for public API Samrat Deb (Jira)
• 2026/03/26 Re: [VOTE] Apache Flink CDC Release 3.6.0, release candidate #2 Junbo Wang
• 2026/03/26 FLIP-556 wiki edit permission question dylanhz
• 2026/03/26 [jira] [Created] (FLINK-39330) FileSourceTextLinesITCase.testBoundedTextFileSourceWithJobManagerFailove fails Piotr Nowojski (Jira)
• 2026/03/26 [jira] [Created] (FLINK-39329) [MySQL-CDC] Improve error message for tables without primary key in incremental snapshot ericzeng (Jira)
• 2026/03/26 Re: [VOTE] Apache Flink CDC Release 3.6.0, release candidate #2 Hang Ruan
• 2026/03/25 Re: [DISCUSS] FLIP-567: Introduce a ProcessTableFunction Test Harness Samrat Deb
• 2026/03/25 [ANNOUNCE] Apache Flink Agents 0.2.1 released wenjin
• 2026/03/25 Re: FLIP-504: Blue/Green Deployments for Flink on Kubernetes - Phase 2 (WIP/Draft PR) Sergio Chong Loo
• 2026/03/25 Re: [DISCUSS] FLIP-569: Sunset the Stateful Functions (StateFun) Sub-project Samrat Deb
• 2026/03/25 Re: [VOTE] FLIP-567: Introduce a ProcessTableFunction Test Harness Hao Li
• 2026/03/25 [jira] [Created] (FLINK-39328) [BUG] When executing DROP TABLE on the source, the following error occurs: Table not exist. zexin gong (Jira)
• 2026/03/25 [jira] [Created] (FLINK-39327) Rename gaussdws pipeline sink connector to dws Daishuyuan (Jira)
• 2026/03/25 Re: [VOTE] FLIP-567: Introduce a ProcessTableFunction Test Harness Rui Fan
• 2026/03/25 Re: [VOTE] FLIP-567: Introduce a ProcessTableFunction Test Harness Natea Eshetu Beshada via dev
• 2026/03/25 Re: Can you check my access? Robert Thomson
• 2026/03/25 Re: Can you check my access? Martijn Visser
• 2026/03/25 Re: [DISCUSS] FLIP-569: Sunset the Stateful Functions (StateFun) Sub-project David Anderson
• 2026/03/25 Re: [DISCUSS] FLIP-569: Sunset the Stateful Functions (StateFun) Sub-project Gustavo de Morais
• 2026/03/25 Re: [VOTE] FLIP-567: Introduce a ProcessTableFunction Test Harness Gustavo de Morais
• 2026/03/25 Re: [DISCUSS] FLIP-567: Introduce a ProcessTableFunction Test Harness Gustavo de Morais
• 2026/03/25 Fwd: Can you check my access? Robert Thomson
• 2026/03/25 [jira] [Created] (FLINK-39326) Flaky DispatcherApplicationTest.testJobResultNotMarkedCleanUntilApplicationTerminates Piotr Nowojski (Jira)
• 2026/03/25 Re: [VOTE] FLIP-567: Introduce a ProcessTableFunction Test Harness Aleksandr Savonin
• 2026/03/25 [DISCUSS] FLIP-572: Introduce Flink-Kafka Transactions Management Tool Aleksandr Savonin
• 2026/03/25 [jira] [Created] (FLINK-39325) Dynamically show/hide rescales tab CHANHAE OH (Jira)
• 2026/03/25 Re: [DISCUSS] FLIP-567: Introduce a ProcessTableFunction Test Harness Mika Naylor
• 2026/03/25 [jira] [Created] (FLINK-39324) Allow MultiJoin to respect IS_NOT_DISTINCT_FROM when extracting join keys Stepan Stepanishchev (Jira)
• 2026/03/25 [jira] [Created] (FLINK-39323) Support SHOW CREATE [OR ALTER] with relative time intervals for FROM_NOW(<interval_expression>) Ramin Gharib (Jira)
• 2026/03/25 Re: [VOTE] Apache Flink CDC Release 3.6.0, release candidate #2 Leonard Xu
• 2026/03/25 [VOTE] Apache Flink CDC Release 3.6.0, release candidate #2 Yanquan Lv
• 2026/03/24 Re: [VOTE] FLIP-567: Introduce a ProcessTableFunction Test Harness Ramin Gharib
• 2026/03/24 [jira] [Created] (FLINK-39322) Add some restore tests about cascaded delta join Xuyang Zhong (Jira)
• 2026/03/24 [DISCUSS] Regarding FLINK-28398 Souptik Barman
• 2026/03/24 [jira] [Created] (FLINK-39321) When writing to Paimon via FlinkCDC , if 'dynamic-bucket.initial-buckets' = '1' is set and the job parallelism is greater than 1, an error will be reported: This is a bug, record assign id %s should equal to assign id %s. Jira
• 2026/03/24 [jira] [Created] (FLINK-39320) Include Kafka record metadata in deserialization error message Pritesh Gudge (Jira)
• 2026/03/24 [jira] [Created] (FLINK-39319) Add immutable columns constraint in Python API Xuyang Zhong (Jira)
• 2026/03/24 Re: [VOTE] Apache Flink CDC Release 3.6.0, release candidate #1 Yanquan Lv
• 2026/03/24 Re: [DISCUSS] FLIP-569: Sunset the Stateful Functions (StateFun) Sub-project Ferenc Csaky
• 2026/03/24 Re: [VOTE] FLIP-567: Introduce a ProcessTableFunction Test Harness Zander Matheson
• 2026/03/24 [jira] [Created] (FLINK-39318) Interruptible timers are not actually enabled for temporal joins Piotr Nowojski (Jira)
• 2026/03/24 [RESULT][VOTE] Apache Flink Agents Release 0.2.1, release candidate #1 wenjin
• 2026/03/24 [jira] [Created] (FLINK-39317) [test] Add e2e test for source connector with Flink 2.2 Yanquan Lv (Jira)
• 2026/03/24 [jira] [Created] (FLINK-39316) BlobServer.getAddress() uses InetAddress.getLocalHost() which fails with VPN networking Jira
• 2026/03/24 Re: [VOTE] Apache Flink CDC Release 3.6.0, release candidate #1 Leonard Xu
• 2026/03/24 [jira] [Created] (FLINK-39315) MySql cdc connector could get stuck in backfill binlog reading after a failover within snapshot phase when the MySql table is being continuously written Cong Cheng (Jira)
• 2026/03/24 Re: [VOTE] Apache Flink CDC Release 3.6.0, release candidate #1 Hongshun Wang
• 2026/03/24 Re: [VOTE] FLIP-567: Introduce a ProcessTableFunction Test Harness Rion Williams
• 2026/03/24 Re: [VOTE] Apache Flink CDC Release 3.6.0, release candidate #1 Leonard Xu
• 2026/03/24 Re: [VOTE] FLIP-567: Introduce a ProcessTableFunction Test Harness Martijn Visser
• 2026/03/24 [jira] [Created] (FLINK-39314) Filter on any upsert key group is sufficient to discard update before in FlinkChangelogModeInferenceProgram Xuyang Zhong (Jira)
• 2026/03/24 [jira] [Created] (FLINK-39313) NDU analyzer misses non-deterministic functions in ChangelogNormalize filter conditions Gustavo de Morais (Jira)
• 2026/03/24 Re:Re: Re: [DISCUSS] FLIP-568: Strict BYTES-to-STRING CAST with UTF-8 Validation Utilities Xuyang
• 2026/03/24 Re: [VOTE] Apache Flink CDC Release 3.6.0, release candidate #1 Yanquan Lv
• 2026/03/24 [DISCUSS] FLIP-571: Support Dynamically Updating Checkpoint Configuration at Runtime via REST API Jiangang Liu
• 2026/03/24 Re: [VOTE] Apache Flink CDC Release 3.6.0, release candidate #1 Shuo Cheng
• 2026/03/24 [jira] [Created] (FLINK-39312) Fix Hudi pipeline connector dependency scope for flink-metrics-dropwizard Shuo Cheng (Jira)
• 2026/03/23 [jira] [Created] (FLINK-39311) Flaky tests in DispatcherApplicationTest Yi Zhang (Jira)
• 2026/03/23 Re: [VOTE] Apache Flink Agents Release 0.2.1, release candidate #1 Weiqing Yang
• 2026/03/23 Re: [DISCUSS] AI-Assisted Contributions and AI Tooling Support in Apache Flink Samrat Deb
• 2026/03/23 [DISCUSS] FLIP-570: Support Runtime Data Sampling for Operators with WebUI Visualization Jiangang Liu
• 2026/03/23 Re: JIRA account Request for Apache Flink Leonard Xu
• 2026/03/23 Fw:JIRA account Request for Apache Flink unigogyk
• 2026/03/23 [jira] [Created] (FLINK-39310) Web UI jar.service.ts passes program-args as string instead of programArgsList array, incompatible with Flink 2.0 REST API Wei H (Jira)
• 2026/03/23 [jira] [Created] (FLINK-39309) Duplicate Submission Check Excludes Terminated Applications Yi Zhang (Jira)
• 2026/03/23 Re: [VOTE] Apache Flink Agents Release 0.2.1, release candidate #1 Eugene
• 2026/03/23 [jira] [Created] (FLINK-39308) Skip empty file-merging operator state snapshots for empty operator list state Ivan Torres (Jira)
• 2026/03/23 [jira] [Created] (FLINK-39307) Improve checkpoint deletion speed in CompletedCheckpoint Shihuan Liu (Jira)
• 2026/03/23 [jira] [Created] (FLINK-39306) Non-source vertices do not use per-second rate metrics, producing inaccurate scaling decisions Dennis-Mircea Ciupitu (Jira)
• 2026/03/23 [jira] [Created] (FLINK-39305) Implement START_MODE for ALTER path of Materialized Table Ramin Gharib (Jira)
• 2026/03/23 [jira] [Created] (FLINK-39304) Support START_MODE clause in the parser Ramin Gharib (Jira)
• 2026/03/23 [jira] [Created] (FLINK-39303) Implement START_MODE clause for Materialized Table Evolution Ramin Gharib (Jira)
• 2026/03/23 [jira] [Created] (FLINK-39302) Handling Idempotency in SHOW CREATE [OR ALTER] for Relative Intervals Ramin Gharib (Jira)
• 2026/03/23 [jira] [Created] (FLINK-39301) FLIP-557: Granular Control over Data Reprocessing in Materialized Table Evolution Ramin Gharib (Jira)
• 2026/03/23 Re: [DISCUSS] FLIP-569: Sunset the Stateful Functions (StateFun) Sub-project Gabor Somogyi
• 2026/03/23 Re: [VOTE] Apache Flink Agents Release 0.2.1, release candidate #1 Xuannan Su
• 2026/03/23 [RESULT][VOTE] FLIP-557: Granular Control over Data Reprocessing in Materialized Table Evolution Ramin Gharib
• 2026/03/23 Re: [DISCUSS] AI-Assisted Contributions and AI Tooling Support in Apache Flink Ramin Gharib
• 2026/03/23 [jira] [Created] (FLINK-39300) [flink-cdc] Reuse ObjectMapper as static constant to avoid repeated instantiation ericzeng (Jira)
• 2026/03/23 [jira] [Created] (FLINK-39299) Parallelism alignment logic in JobVertexScaler#scale can cancel, invert, or overshoot scaling decisions for source partition-aware vertices Dennis-Mircea Ciupitu (Jira)
• 2026/03/23 Re: [DISCUSS] AI-Assisted Contributions and AI Tooling Support in Apache Flink Gustavo de Morais

• Earlier messages