dev

Messages by Date

2026/04/15 Re: [DISCUSS] FLIP-571: Support Dynamically Updating Checkpoint Configuration at Runtime via REST API Verne Deng
2026/04/15 [DISUCUSS] FLIP-XXX: Composable Parallelism Alignment Modes for Flink Autoscaler Dennis-Mircea Ciupitu
2026/04/15 FLIP-XXX: Composable Parallelism Alignment Modes for Flink Autoscaler Dennis-Mircea Ciupitu
2026/04/15 Re: [DISCUSS] FLIP-571: Support Dynamically Updating Checkpoint Configuration at Runtime via REST API 熊饶饶
2026/04/14 Re: [DISCUSS] FLIP-574: Metadata Filter Push-Down for Table Sources Sergey Nuyanzin
2026/04/14 [jira] [Created] (FLINK-39438) Add configurable sink operation (upsert/append) for MaxCompute sink in Flink CDC Dion Ricky Saputra (Jira)
2026/04/14 RE: [DISCUSS] Release flink-connector-kafka v5.0.0 MUKUL GUPTA via dev
2026/04/14 Re: [DISCUSS] Flink 1.20.4, 2.0.2, 2.1.2, 2.2.1 releases weijie guo
2026/04/14 Re: [DISCUSS] Flink 1.20.4, 2.0.2, 2.1.2, 2.2.1 releases Leonard Xu
2026/04/14 Re: [DISCUSS] Hive 3.1 connector broken on Java 11+ (URLClassLoader cast in SessionState) Ferenc Csaky
2026/04/14 Re: [DISCUSS] Flink 1.20.4, 2.0.2, 2.1.2, 2.2.1 releases Ferenc Csaky
2026/04/14 Re: [DISCUSS] Hive 3.1 connector broken on Java 11+ (URLClassLoader cast in SessionState) Martijn Visser
2026/04/14 [DISCUSS] FLINK-39404: HardwareDescription cpuCores - int to double breaking change Dennis-Mircea Ciupitu
2026/04/14 [jira] [Created] (FLINK-39437) Support interruptible timers in PTFs Timo Walther (Jira)
2026/04/14 [jira] [Created] (FLINK-39436) Allow late data to enter PTF Timo Walther (Jira)
2026/04/14 Re: [DISCUSS] Flink 1.20.4, 2.0.2, 2.1.2, 2.2.1 releases Rui Fan
2026/04/14 Re: [DISCUSS] Flink 1.20.4, 2.0.2, 2.1.2, 2.2.1 releases Gustavo de Morais
2026/04/14 [jira] [Created] (FLINK-39435) [flink-connector-kafka] Switching Kafka topics via Savepoint restore causes dual-topic consumption AND new topic consumed from earliest instead of configured offset sherlock-lin (Jira)
2026/04/14 Re: [DISCUSS] FLIP-XXX: Enhancing HistoryServer with Lazy Loading and Pluggable Storage Feng Jin
2026/04/13 Re: [DISCUSS] FLIP-XXX: Scaling Executor Plugin SPI for Flink Autoscaler gyula . fora
2026/04/13 [jira] [Created] (FLINK-39434) Transform table-options changes are not propagated to existing downstream tables on savepoint restart Vinay Sagar Gonabavi (Jira)
2026/04/13 [jira] [Created] (FLINK-39433) Consolidate scattered Hive reflection calls into HiveShim for type safety Jayesh Lalwani (Jira)
2026/04/13 [DISCUSS] Hive 3.1 connector broken on Java 11+ (URLClassLoader cast in SessionState) Lalwani, Jayesh
2026/04/13 [RESULT][VOTE] FLIP-568: Strict BYTES-to-STRING CAST with UTF-8 Validation Utilities Gustavo de Morais
2026/04/13 [DISCUSS] FLIP-XXX: Scaling Executor Plugin SPI for Flink Autoscaler Dennis-Mircea Ciupitu
2026/04/13 Re: [DISCUSS] FLIP-574: Metadata Filter Push-Down for Table Sources Timo Walther
2026/04/13 [DISCUSS] FLINK-39320: Include Kafka record metadata in deserialization error message Pritesh Gudge via dev
2026/04/13 [jira] [Created] (FLINK-39432) Add option to delete session with running session jobs Gyula Fora (Jira)
2026/04/13 [DISCUSS] JDBC Sink: reWriteBatchedInserts=true incompatible with INSERT … ON CONFLICT DO UPDATE when batch contains duplicate keys Christian Stein
2026/04/13 [jira] [Created] (FLINK-39431) The s3 connector is not able to be configured due to config name collision Gabor Somogyi (Jira)
2026/04/13 [jira] [Created] (FLINK-39430) Add `invalid_op_handling` parameter to FROM_CHANGELOG PTF Ramin Gharib (Jira)
2026/04/13 [DISCUSS] Flink 1.20.4, 2.0.2, 2.1.2, 2.2.1 releases Sergey Nuyanzin
2026/04/13 [jira] [Created] (FLINK-39429) NoClassDefFoundError for flink-shaded-guava31 in IncrementalSourceStreamFetcher (Flink 2.2 / CDC 3.6.0) Jira
2026/04/13 Re: [DISCUSS] FLIP-570: Support Runtime Data Sampling for Operators with WebUI Visualization Jiangang Liu
2026/04/13 [jira] [Created] (FLINK-39428) MDC 对于有些线程池是缺失的 lizhiqiang (Jira)
2026/04/12 Re: [DISCUSS] FLIP-570: Support Runtime Data Sampling for Operators with WebUI Visualization Yuepeng Pan
2026/04/12 Re: Re: [VOTE] FLIP-568: Strict BYTES-to-STRING CAST with UTF-8 Validation Utilities weijie guo
2026/04/12 [jira] [Created] (FLINK-39427) Use Apache Parent POM 35 Sergey Nuyanzin (Jira)
2026/04/12 [jira] [Created] (FLINK-39426) Flink 2.0 and Connector version compatibility issue Xueyan Wang (Jira)
2026/04/12 [jira] [Created] (FLINK-39425) [flink-metrics-otel] OpenTelemetryEventReporter ignores service.name and service.version config Sameer Devgan (Jira)
2026/04/12 [jira] [Created] (FLINK-39424) Setting LIKE does not support default escape characters. Qilong Wang (Jira)
2026/04/11 Re: [DISCUSS] FLIP-573: Kafka Share Groups for Queue-Like Event Processing in Flink Connector Kafka Shekhar Rajak
2026/04/11 [DISCUSS] FLIP-573: Kafka Share Groups for Queue-Like Event Processing in Flink Connector Kafka Shekhar Rajak
2026/04/11 [jira] [Created] (FLINK-39423) Fix PseudoRandomValueSelector.randomize() producing identical values for all boolean config options Rui Fan (Jira)
2026/04/10 [jira] [Created] (FLINK-39422) [FLINK][OpenAPI] OpenApiSpecGenerator produces incorrect schemas for types with custom Jackson serializers Nikhil S (Jira)
2026/04/10 [DISCUSS] FLIP-574: Metadata Filter Push-Down for Table Sources Jim Hughes via dev
2026/04/10 [jira] [Created] (FLINK-39421) Metadata filter push-down for table sources Jim Hughes (Jira)
2026/04/10 Re: [DISCUSS] Adding Apache Hive 4.x support to flink-connector-hive Lalwani, Jayesh
2026/04/10 Re: [DISCUSS] FLIP-571: Support Dynamically Updating Checkpoint Configuration at Runtime via REST API Roman Khachatryan
2026/04/10 [jira] [Created] (FLINK-39420) Temporal joins on non-lookup tables in batch mode produce a confusing internal error Jim Hughes (Jira)
2026/04/10 Re: [DISCUSS] FLIP-572: Introduce Flink-Kafka Transactions Management Tool Aleksandr Savonin
2026/04/10 Re: [DISCUSS] FLIP-572: Introduce Flink-Kafka Transactions Management Tool Aleksandr Savonin
2026/04/10 Re: [DISCUSS] FLIP-570: Support Runtime Data Sampling for Operators with WebUI Visualization Jiangang Liu
2026/04/10 [jira] [Created] (FLINK-39419) Support TO_CHANGELOG: Any stream -> flat records with partial and full deletes (4.2.2.5, 4.2.2.6) Gustavo de Morais (Jira)
2026/04/10 [jira] [Created] (FLINK-39418) YAML pipeline supports decimal with 19+ precision and scale Xiqian Yu (Jira)
2026/04/10 [jira] [Created] (FLINK-39417) YAML Pipeline could not [de]serialize GenericRecordData Xiqian Yu (Jira)
2026/04/09 Re: [DISCUSS] FLIP-570: Support Runtime Data Sampling for Operators with WebUI Visualization Yuepeng Pan
2026/04/09 [jira] [Created] (FLINK-39416) Fix link address errors in documents peiyu (Jira)
2026/04/09 Re: [DISCUSS] FLIP-570: Support Runtime Data Sampling for Operators with WebUI Visualization Jiangang Liu
2026/04/09 Re: [DISCUSS] FLIP-570: Support Runtime Data Sampling for Operators with WebUI Visualization xingsuo-zbz
2026/04/09 Re: [DISCUSS] FLIP-570: Support Runtime Data Sampling for Operators with WebUI Visualization Jiangang Liu
2026/04/09 Re: [DISCUSS] FLIP-570: Support Runtime Data Sampling for Operators with WebUI Visualization Look_Y_Y
2026/04/09 Re: [DISCUSS] FLIP-570: Support Runtime Data Sampling for Operators with WebUI Visualization Jiangang Liu
2026/04/09 [jira] [Created] (FLINK-39415) [flink-cdc-postgres] TIMESTAMPTZ type mapping causes NumberFormatException in Pipeline connector with Iceberg sink Avichay Marciano (Jira)
2026/04/09 [DISCUSS][FLINK-35321] CheckpointCommittableManagerImpl re-registers pendingCommittables gauge on every commit operation - request for approval Piotr Rudnicki
2026/04/09 [jira] [Created] (FLINK-39414) TaskExecutorPartitionLifecycleTest#testEnableBatchJobRecoveryAnd* take long time to complete Matthias Pohl (Jira)
2026/04/09 [jira] [Created] (FLINK-39413) TaskExecutorSubmissionTest#testRemotePartitionNotFound needs 20s to finish Matthias Pohl (Jira)
2026/04/09 Re: [ANNOUNCE] New Apache Flink Committer - Wenjie Xie Jacky Lau
2026/04/09 Re: [ANNOUNCE] New Apache Flink Committer - Wenjie Xie Yuepeng Pan
2026/04/08 Re: [ANNOUNCE] New Apache Flink Committer - Wenjie Xie dylanhz
2026/04/08 Re: [ANNOUNCE] New Apache Flink Committer - Wenjie Xie Hongshun Wang
2026/04/08 [jira] [Created] (FLINK-39412) AddColumnEvent fails with duplicate field names when schema change events are replayed after failover kianwee (Jira)
2026/04/08 Re: [ANNOUNCE] New Apache Flink Committer - Wenjie Xie Jiangang Liu
2026/04/08 Re: [ANNOUNCE] New Apache Flink Committer - Wenjie Xie Yanquan Lv
2026/04/08 [jira] [Created] (FLINK-39411) PTF code generation uses wrong type for table arguments — METADATA VIRTUAL columns inaccessible Natea Eshetu Beshada (Jira)
2026/04/08 [DISCUSS] Adding Apache Hive 4.x support to flink-connector-hive Lalwani, Jayesh
2026/04/08 [SUMMARY] Flink 2.3 release sync (Apr 7) David Anderson
2026/04/08 [jira] [Created] (FLINK-39410) The `flink-cdc-pipeline-connector-elasticsearch` module offers better compatibility with Flink 1.20 and Flink 2.x. peiyu (Jira)
2026/04/08 Re: [DISCUSS] FLIP-570: Support Runtime Data Sampling for Operators with WebUI Visualization Jiangang Liu
2026/04/08 Re: [DISCUSS] FLIP-570: Support Runtime Data Sampling for Operators with WebUI Visualization 熊饶饶
2026/04/08 Re: [DISCUSS] FLIP-571: Support Dynamically Updating Checkpoint Configuration at Runtime via REST API zhao_abc_123
2026/04/08 ???????? ????
2026/04/08 Re: [DISCUSS] FLIP-571: Support Dynamically Updating Checkpoint Configuration at Runtime via REST API 熊饶饶
2026/04/07 Re: [ANNOUNCE] New Apache Flink Committer - Wenjie Xie Hang Ruan
2026/04/07 Re: [DISCUSS] FLIP-572: Introduce Flink-Kafka Transactions Management Tool Shekhar Rajak
2026/04/07 [jira] [Created] (FLINK-39409) Support tables without primary key for incremental snapshot Di Wu (Jira)
2026/04/07 Re: [ANNOUNCE] New Apache Flink Committer - Wenjie Xie Leonard Xu
2026/04/07 Re: [ANNOUNCE] New Apache Flink Committer - Wenjie Xie Yuan Mei
2026/04/07 Re: [ANNOUNCE] New Apache Flink Committer - Wenjie Xie 吴晓军
2026/04/07 Re: [DISCUSS] FLIP-572: Introduce Flink-Kafka Transactions Management Tool Hongshun Wang
2026/04/07 Re: [ANNOUNCE] New Apache Flink Committer - Wenjie Xie Amos Aidoo
2026/04/07 Re: [ANNOUNCE] New Apache Flink Committer - Wenjie Xie Samrat Deb
2026/04/07 Re: [ANNOUNCE] New Apache Flink Committer - Wenjie Xie Eugene
2026/04/07 [jira] [Created] (FLINK-39408) TestNameProvider broken after JUnit 5 migration Rui Fan (Jira)
2026/04/07 Re: [ANNOUNCE] New Apache Flink Committer - Wenjie Xie Yash Anand via dev
2026/04/07 Re: [ANNOUNCE] New Apache Flink Committer - Wenjie Xie Weiqing Yang
2026/04/07 [jira] [Created] (FLINK-39407) CreateTableEvent failed in MySQL to Paimon pipeline Edward Zhang (Jira)
2026/04/07 来自王珂的邮件王珂
2026/04/07 Re: [ANNOUNCE] New Apache Flink Committer - Wenjie Xie Gustavo de Morais
2026/04/07 Re: [ANNOUNCE] New Apache Flink Committer - Wenjie Xie Geng Biao
2026/04/07 [ANNOUNCE] New Apache Flink Committer - Wenjie Xie Xintong Song
2026/04/07 [jira] [Created] (FLINK-39406) Can not read partition table in oracle connector Jia Fan (Jira)
2026/04/07 [jira] [Created] (FLINK-39405) Fix default escape character document display errors Qilong Wang (Jira)
2026/04/07 [DISCUSS] FLIP-XXX: Support Window Stagger in FlinkSQL and introduce KEY_BASED deterministic stagger zihao chen
2026/04/06 RE: HTTP connector Ferenc Csaky
2026/04/06 [jira] [Created] (FLINK-39404) HardwareDescription reports incorrect CPU cores in containerized environments with fractional CPU limits Dennis-Mircea Ciupitu (Jira)
2026/04/06 [jira] [Created] (FLINK-39403) Postgres snapshotting phase might cause transaction leak Levani Kokhreidze (Jira)
2026/04/06 [jira] [Created] (FLINK-39402) Fix LIKE quick path ignoring default escape character '\' Qilong Wang (Jira)
2026/04/05 [jira] [Created] (FLINK-39401) [format] Extend Raw Format to Support Line Delimiter and Multi-Row Splitting featzhang (Jira)
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