issues  

Messages by Date

• 2026/03/11 Re: [PR] [FLINK-39231][test][sqlserver] Fix unstable sqlserver connector test [flink-cdc] via GitHub
• 2026/03/11 Re: [PR] [FLINK-39231][test][sqlserver] Fix unstable sqlserver connector test [flink-cdc] via GitHub
• 2026/03/11 [jira] [Commented] (FLINK-39135) Backport GSBlobStorageImpl precondition check to 1.20.4 Jon Chase (Jira)
• 2026/03/11 [jira] [Commented] (FLINK-39136) GS file system fails to retry on certain 503's due to old GCS lib dependency Jon Chase (Jira)
• 2026/03/11 Re: [PR] [FLINK-38729] Add support for Flink 2.2.0 [flink-cdc] via GitHub
• 2026/03/11 Re: [PR] [FLINK-38729] Add support for Flink 2.2.0 [flink-cdc] via GitHub
• 2026/03/11 [jira] [Commented] (FLINK-39225) Add retry with default value fallback for triton inference failures Jira
• 2026/03/11 Re: [PR] [FLINK-39117] Fix flaky ChainUnionTest [flink] via GitHub
• 2026/03/11 Re: [PR] [FLINK-38830][runtime] Handle duplicate AddColumnEvent gracefully to prevent pipeline crashes [flink-cdc] via GitHub
• 2026/03/11 Re: [PR] [FLINK-38830][runtime] Handle duplicate AddColumnEvent gracefully to prevent pipeline crashes [flink-cdc] via GitHub
• 2026/03/11 Re: [PR] [FLINK-38830][runtime] Handle duplicate AddColumnEvent gracefully to prevent pipeline crashes [flink-cdc] via GitHub
• 2026/03/11 Re: [PR] [FLINK-38830][runtime] Handle duplicate AddColumnEvent gracefully to prevent pipeline crashes [flink-cdc] via GitHub
• 2026/03/11 Re: [PR] [FLINK-38592] Initial Native Flink S3 FileSystem [flink] via GitHub
• 2026/03/11 Re: [PR] [FLINK-38592] Initial Native Flink S3 FileSystem [flink] via GitHub
• 2026/03/11 Re: [PR] fix: warning for conditional [flink] via GitHub
• 2026/03/11 [PR] fix: warning for conditional [flink] via GitHub
• 2026/03/11 [jira] [Updated] (FLINK-39218) Add CLI tool to manage lingering Kafka transactions ASF GitHub Bot (Jira)
• 2026/03/11 [PR] [FLINK-39218] Add CLI tool to manage lingering Kafka transactions [flink-connector-kafka] via GitHub
• 2026/03/11 Re: [PR] [FLINK-38822] Introduce URL_DECODE_RECURSIVE function for recursive URL decoding [flink] via GitHub
• 2026/03/11 Re: [PR] [FLINK-38592] Initial Native Flink S3 FileSystem [flink] via GitHub
• 2026/03/11 Re: [PR] [FLINK-38592] Initial Native Flink S3 FileSystem [flink] via GitHub
• 2026/03/11 [jira] [Closed] (FLINK-39242) Method getDataType does not exist error when getting columns from ResolvedSchema Timo Walther (Jira)
• 2026/03/11 Re: [PR] [FLINK-39242][python] Fix error when getting columns from ResolvedSchema [flink] via GitHub
• 2026/03/11 Re: [PR] [hotfix] Fix incorrect JavaDoc for session window assigners [flink] via GitHub
• 2026/03/11 Re: [PR] [FLINK-38592] Initial Native Flink S3 FileSystem [flink] via GitHub
• 2026/03/11 Re: [PR] [FLINK-38592] Initial Native Flink S3 FileSystem [flink] via GitHub
• 2026/03/11 Re: [PR] [FLINK-38592] Initial Native Flink S3 FileSystem [flink] via GitHub
• 2026/03/11 Re: [PR] [FLINK-39117] Fix flaky ChainUnionTest [flink] via GitHub
• 2026/03/11 [PR] [connector-http] Add request timeout config option [flink-connector-http] via GitHub
• 2026/03/11 [PR] [hotfix] Avoid unnecessary scale-down when recommended parallelism equals current parallelism in delay window. [flink-kubernetes-operator] via GitHub
• 2026/03/11 Re: [PR] [FLINK-39081] Add ARTIFACT keyword option in CREATE FUNCTION's USING clause [flink] via GitHub
• 2026/03/11 Re: [PR] [FLINK-39244][table] Support precision 0-9 for TO_TIMESTAMP_LTZ function [flink] via GitHub
• 2026/03/11 [PR] [FLINK-39244][table] Support precision 0-9 for TO_TIMESTAMP_LTZ function [flink] via GitHub
• 2026/03/11 [jira] [Updated] (FLINK-39244) Support precision 0-9 for TO_TIMESTAMP_LTZ function ASF GitHub Bot (Jira)
• 2026/03/11 Re: [PR] Update CI for Flink Connector Parent POM 2.0 compatibility [flink-connector-shared-utils] via GitHub
• 2026/03/11 [jira] [Updated] (FLINK-39243) Include `observedGeneration` for Suspended Flink Deployments Yanis Djeridi (Jira)
• 2026/03/11 Re: [PR] [FLINK-38592] Initial Native Flink S3 FileSystem [flink] via GitHub
• 2026/03/11 Re: [PR] [FLINK-38592] Initial Native Flink S3 FileSystem [flink] via GitHub
• 2026/03/11 [jira] [Created] (FLINK-39244) Support precision 0-9 for TO_TIMESTAMP_LTZ function Ramin Gharib (Jira)
• 2026/03/11 [jira] [Created] (FLINK-39243) Include `observedGeneration` for Suspended Flink Deployments Yanis Djeridi (Jira)
• 2026/03/11 Re: [PR] [FLINK-39220] Add unit tests for ConditionsUtils [flink-kubernetes-operator] via GitHub
• 2026/03/11 Re: [PR] [FLINK-39242][python] Fix error when getting columns from ResolvedSchema [flink] via GitHub
• 2026/03/11 [jira] [Updated] (FLINK-39242) Method getDataType does not exist error when getting columns from ResolvedSchema ASF GitHub Bot (Jira)
• 2026/03/11 Re: [PR] [FLINK-39175][table-planner] Remove unnecessary check about calc with non-deterministic func in DuplicateChangesInferRule [flink] via GitHub
• 2026/03/11 [PR] [FLINK-39242][python] Fix error when getting columns from ResolvedSchema [flink] via GitHub
• 2026/03/11 [jira] [Commented] (FLINK-39223) IllegalStateException: Failed to send request to coordinator: SchemaChangeRequest vertern (Jira)
• 2026/03/11 Re: [PR] [FLINK-38592] Initial Native Flink S3 FileSystem [flink] via GitHub
• 2026/03/11 [PR] [connector-http] Improve README with SQL examples [flink-connector-http] via GitHub
• 2026/03/11 [jira] [Created] (FLINK-39242) Method getDataType does not exist error when getting columns from ResolvedSchema Mika Naylor (Jira)
• 2026/03/11 Re: [PR] [FLINK-39240][runtime] Jobs share application-level jar when possible [flink] via GitHub
• 2026/03/11 [jira] [Updated] (FLINK-39240) Jobs share application-level jar when possible ASF GitHub Bot (Jira)
• 2026/03/11 [PR] [FLINK-39240][runtime] Jobs share application-level jar when possible [flink] via GitHub
• 2026/03/11 Re: [PR] [FLINK-39231][test][sqlserver] Fix unstable sqlserver connector test [flink-cdc] via GitHub
• 2026/03/11 Re: [PR] [FLINK-38522][cdc connector mysql] use ssl for BinaryLogClient when searching for binlog offset for starting mysql cdc from timestamp [flink-cdc] via GitHub
• 2026/03/11 Re: [PR] [FLINK-38244][hotfix] Fix the full snapshot phase, the field case is adjusted based on isTableIdCaseInsensitive [flink-cdc] via GitHub
• 2026/03/11 [jira] [Comment Edited] (FLINK-38972) FLIP-560: Application Capability Enhancement Rui Fan (Jira)
• 2026/03/11 [jira] [Updated] (FLINK-38972) FLIP-560: Application Capability Enhancement Rui Fan (Jira)
• 2026/03/11 Re: [PR] [FLINK-38592] Initial Native Flink S3 FileSystem [flink] via GitHub
• 2026/03/11 [jira] [Updated] (FLINK-38972) FLIP-560: Application Capability Enhancement Rui Fan (Jira)
• 2026/03/11 Re: [PR] [FLINK-36520] CDC Supports MySQL 8.x and above [flink-cdc] via GitHub
• 2026/03/11 [jira] [Updated] (FLINK-38972) FLIP-560: Application Capability Enhancement Rui Fan (Jira)
• 2026/03/11 [jira] [Commented] (FLINK-38972) FLIP-560: Application Capability Enhancement Rui Fan (Jira)
• 2026/03/11 [jira] [Updated] (FLINK-38972) FLIP-560: Application Capability Enhancement Rui Fan (Jira)
• 2026/03/11 [jira] [Updated] (FLINK-38972) FLIP-560: Application Capability Enhancement Rui Fan (Jira)
• 2026/03/11 [jira] [Updated] (FLINK-38972) FLIP-560: Application Capability Enhancement Rui Fan (Jira)
• 2026/03/11 [jira] [Updated] (FLINK-38972) FLIP-560: Application Capability Enhancement Rui Fan (Jira)
• 2026/03/11 Re: [PR] [FLINK-39202][table] Add new SimplifyCoalesceWithEquiJoinConditionRule [flink] via GitHub
• 2026/03/11 [jira] [Updated] (FLINK-39234) KafkaWriterFaultToleranceITCase flakiness due to NotLeaderOrFollowerException ASF GitHub Bot (Jira)
• 2026/03/11 [PR] [FLINK-39234][tests] Wait for topic intialization in KafkaWriterTestBase based tests [flink-connector-kafka] via GitHub
• 2026/03/11 [jira] [Updated] (FLINK-39241) Incorrect row data using in MultiJoinStateViews for HeapStateBackend case Dmitriy Linevich (Jira)
• 2026/03/11 [jira] [Updated] (FLINK-39241) Incorrect row data using in MultiJoinStateViews for HeapStateBackend case Dmitriy Linevich (Jira)
• 2026/03/11 [jira] [Updated] (FLINK-39241) Incorrect row data using in MultiJoinStateViews for HeapStateBackend case Dmitriy Linevich (Jira)
• 2026/03/11 [jira] [Updated] (FLINK-39151) Hide warning about UnixOperatingSystemMXBean missing on Windows Piotr Przybylski (Jira)
• 2026/03/11 [jira] [Created] (FLINK-39241) Incorrect row data using in MultiJoinStateViews for HeapStateBackend case Dmitriy Linevich (Jira)
• 2026/03/11 Re: [PR] [FLINK-39209][doris] Fix time data type serialiazation when sink to doris with pipeline connector [flink-cdc] via GitHub
• 2026/03/11 Re: [PR] [FLINK-39065][Formats (JSON, Avro, Parquet, ORC, SequenceFile)] Support additional CsvParser.Feature options for CSV format deserialization [flink] via GitHub
• 2026/03/11 Re: [PR] [FLINK-38592] Initial Native Flink S3 FileSystem [flink] via GitHub
• 2026/03/11 [jira] [Updated] (FLINK-39235) Re implement HTTP Connector constants support David Radley (Jira)
• 2026/03/11 [jira] [Updated] (FLINK-39235) Re implement HTTP Connector constants support David Radley (Jira)
• 2026/03/11 Re: [PR] [FLINK-39000] Avoid redundant seeks during operator list state restore [flink] via GitHub
• 2026/03/11 [jira] [Updated] (FLINK-39235) Re implement HTTP Connector constants support David Radley (Jira)
• 2026/03/11 Re: [PR] [FLINK-39015][table] Fix key extractor for multi join. Change GenericRowData to BinaryRowData [flink] via GitHub
• 2026/03/11 [jira] (FLINK-39225) Add retry with default value fallback for triton inference failures Jira
• 2026/03/11 [jira] [Commented] (FLINK-39225) Add retry with default value fallback for triton inference failures Jira
• 2026/03/11 Re: [PR] [FLINK-39015][table] Fix key extractor for multi join. Change GenericRowData to BinaryRowData [flink] via GitHub
• 2026/03/11 Re: [PR] [hotfix] Fix db2 Db2Dialect error [flink-connector-jdbc] via GitHub
• 2026/03/11 [jira] [Updated] (FLINK-39209) Flink cdc doris connector throw exception when serializing time data type columns Cong Cheng (Jira)
• 2026/03/11 [jira] [Comment Edited] (FLINK-39209) Flink cdc doris connector throw exception when serializing time data type columns Cong Cheng (Jira)
• 2026/03/11 Re: [PR] [FLINK-38729] Add support for Flink 2.2.0 [flink-cdc] via GitHub
• 2026/03/11 [PR] [FLINK-39209][doris] Fix time data type serialiazation when sink to doris with pipeline connector [flink-cdc] via GitHub
• 2026/03/11 [jira] [Updated] (FLINK-39209) Flink cdc doris connector throw exception when serializing time data type columns ASF GitHub Bot (Jira)
• 2026/03/11 [jira] [Updated] (FLINK-39209) Flink cdc doris connector throw exception when serializing time data type columns Cong Cheng (Jira)
• 2026/03/11 [jira] [Updated] (FLINK-39209) Flink cdc doris connector throw exception when serializing time data type columns Cong Cheng (Jira)
• 2026/03/11 Re: [PR] fix db2 Db2Dialect error [flink-connector-jdbc] via GitHub
• 2026/03/11 Re: [PR] fix db2 Db2Dialect error [flink-connector-jdbc] via GitHub
• 2026/03/11 [jira] [Created] (FLINK-39240) Jobs share application-level jar when possible Yi Zhang (Jira)
• 2026/03/11 Re: [PR] [FLINK-39015][table] Fix key extractor for multi join. Change GenericRowData to BinaryRowData [flink] via GitHub
• 2026/03/11 [jira] [Created] (FLINK-39239) no viable alternative at input 'ENABLE LOGICAL' io.debezium.text.ParsingException: DDL statement couldn't be parsed. Please open a Jira issue with the statement sunmaosen (Jira)
• 2026/03/11 Re: [PR] Community blog March 2026 [flink-web] via GitHub
• 2026/03/10 Re: [PR] Community blog March 2026 [flink-web] via GitHub
• 2026/03/10 Re: [PR] fix db2 Db2Dialect error [flink-connector-jdbc] via GitHub
• 2026/03/10 Re: [PR] Bump io.netty:netty-codec-http from 4.1.108.Final to 4.1.127.Final-redhat-00001 in /flink-kubernetes [flink] via GitHub
• 2026/03/10 Re: [PR] Bump io.netty:netty-codec-http from 4.1.108.Final to 4.1.127.Final-redhat-00001 in /flink-kubernetes [flink] via GitHub
• 2026/03/10 Re: [PR] Bump io.netty:netty-codec-http from 4.1.108.Final to 4.1.127.Final-redhat-00001 in /flink-kubernetes [flink] via GitHub
• 2026/03/10 Re: [PR] [FLINK-38729] Add support for Flink 2.2.0 [flink-cdc] via GitHub
• 2026/03/10 Re: [PR] [FLINK-39178][table-planner] Support cascaded delta join in planner [flink] via GitHub
• 2026/03/10 Re: [PR] [FLINK-39178][table-planner] Support cascaded delta join in planner [flink] via GitHub
• 2026/03/10 [jira] [Updated] (FLINK-39175) Remove unnecessary check about calc with non-deterministic func in DuplicateChangesInferRule Xuyang Zhong (Jira)
• 2026/03/10 [jira] [Updated] (FLINK-39175) Remove unnecessary check about calc with non-deterministic func in DuplicateChangesInferRule Xuyang Zhong (Jira)
• 2026/03/10 Re: [PR] [FLINK-38729] Add support for Flink 2.2.0 [flink-cdc] via GitHub
• 2026/03/10 [jira] [Updated] (FLINK-39219) Support lineage extraction for DataStreamscan/sink providers ASF GitHub Bot (Jira)
• 2026/03/10 Re: [PR] [FLINK-39219] [table] Support lineage extraction for DataStreamscan/sink providers [flink] via GitHub
• 2026/03/10 Re: [PR] [FLINK-39219] [table] Support lineage extraction for DataStreamscan/sink providers [flink] via GitHub
• 2026/03/10 Re: [PR] [FLINK-38373][Connectors / ElasticSearch] Support dynamic index generation with field value suffix [flink-connector-elasticsearch] via GitHub
• 2026/03/10 Re: [PR] [FLINK-38822] Introduce URL_DECODE_RECURSIVE function for recursive URL decoding [flink] via GitHub
• 2026/03/10 Re: [PR] [FLINK-39015][table] Fix key extractor for multi join. Change GenericRowData to BinaryRowData [flink] via GitHub
• 2026/03/10 Re: [I] [Feature] Add support for custom job name in Flink Agents Job execution [flink-agents] via GitHub
• 2026/03/10 Re: [I] [Feature] Add support for custom job name in Flink Agents Job execution [flink-agents] via GitHub
• 2026/03/10 Re: [PR] [FLINK-39236][table] Adapt binary delta join runtime operator to structure of cascade delta join [flink] via GitHub
• 2026/03/10 [jira] [Updated] (FLINK-39236) Adapt binary delta join runtime operator to structure of cascade delta join ASF GitHub Bot (Jira)
• 2026/03/10 [PR] [FLINK-39236][table] Adapt binary delta join runtime operator to structure of cascade delta join [flink] via GitHub
• 2026/03/10 Re: [PR] [FLINK-39117] Fix flaky ChainUnionTest [flink] via GitHub
• 2026/03/10 Re: [PR] [FLINK-35459] Use Incremental Source Framework in Flink tidb CDC Source Connector [flink-cdc] via GitHub
• 2026/03/10 Re: [PR] Bump tar and @angular/cli in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/03/10 Re: [PR] Bump tar and @angular/cli in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/03/10 [PR] Bump tar and @angular/cli in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/03/10 Re: [PR] Bump tar and @angular/cli in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/03/10 Re: [PR] Community blog March 2026 [flink-web] via GitHub
• 2026/03/10 Re: [PR] Community blog March 2026 [flink-web] via GitHub
• 2026/03/10 Re: [PR] Community blog March 2026 [flink-web] via GitHub
• 2026/03/10 Re: [PR] Update CI for Flink Connector Parent POM 2.0 compatibility [flink-connector-shared-utils] via GitHub
• 2026/03/10 Re: [PR] [FLINK-39202][table] Add new SimplifyCoalesceWithEquiJoinConditionRule [flink] via GitHub
• 2026/03/10 Re: [PR] [FLINK-39202][table] Add new SimplifyCoalesceWithEquiJoinConditionRule [flink] via GitHub
• 2026/03/10 Re: [PR] [plan] Extract ResourceCache and PythonResourceBridge from AgentPlan [flink-agents] via GitHub
• 2026/03/10 Re: [PR] [FLINK-39117] Fix flaky ChainUnionTest [flink] via GitHub
• 2026/03/10 Re: [PR] Community blog March 2026 [flink-web] via GitHub
• 2026/03/10 Re: [PR] [hotfix] Fix grammar [flink-connector-http] via GitHub
• 2026/03/10 [jira] [Created] (FLINK-39238) Support watermark alignment in flink-connector-kafka in dynamic Kafka source mode Xin Gao (Jira)
• 2026/03/10 Re: [PR] [FLINK-38096] AsyncSinkWriter may hang when configured with a custom rate limiting strategy [flink] via GitHub
• 2026/03/10 Re: [PR] [FLINK-34415] Move away from Kafka-Zookeeper based tests in favor of Kafka-KRaft [flink] via GitHub
• 2026/03/10 [jira] [Updated] (FLINK-34415) Move away from Kafka-Zookeeper based tests in favor of Kafka-KRaft ASF GitHub Bot (Jira)
• 2026/03/10 [PR] [FLINK-34415] Move away from Kafka-Zookeeper based tests in favor of Kafka-KRaft [flink] via GitHub
• 2026/03/10 [jira] [Updated] (FLINK-39002) Could not resolve ResourceManager because of NPE Roman Khachatryan (Jira)
• 2026/03/10 [jira] [Updated] (FLINK-39002) Could not resolve ResourceManager because of NPE Roman Khachatryan (Jira)
• 2026/03/10 [jira] [Closed] (FLINK-39002) Could not resolve ResourceManager because of NPE Roman Khachatryan (Jira)
• 2026/03/10 [jira] [Commented] (FLINK-39002) Could not resolve ResourceManager because of NPE Roman Khachatryan (Jira)
• 2026/03/10 Re: [PR] [FLINK-38096] AsyncSinkWriter may hang when configured with a custom rate limiting strategy [flink] via GitHub
• 2026/03/10 Re: [PR] [FLINK-38970] Fix flaky AdaptiveBatchSchedulerTest by using synchrono… [flink] via GitHub
• 2026/03/10 Re: [PR] [FLINK-38727] Fix flaky test by adding slot request timeout configura… [flink] via GitHub
• 2026/03/10 Re: [PR] [FLINK-39117] Fix flaky ChainUnionTest [flink] via GitHub
• 2026/03/10 Re: [PR] [FLINK-38096] AsyncSinkWriter may hang when configured with a custom rate limiting strategy [flink] via GitHub
• 2026/03/10 Re: [PR] [FLINK-39015][table] Fix key extractor for multi join. Change GenericRowData to BinaryRowData [flink] via GitHub
• 2026/03/10 Re: [PR] [FLINK-39015][table] Fix key extractor for multi join. Change GenericRowData to BinaryRowData [flink] via GitHub
• 2026/03/10 Re: [PR] [FLINK-39015][table] Fix key extractor for multi join. Change GenericRowData to BinaryRowData [flink] via GitHub
• 2026/03/10 Re: [PR] [FLINK-38096] AsyncSinkWriter may hang when configured with a custom rate limiting strategy [flink] via GitHub
• 2026/03/10 Re: [PR] [FLINK-38592] Initial Native Flink S3 FileSystem [flink] via GitHub
• 2026/03/10 Re: [PR] [FLINK-38096] AsyncSinkWriter may hang when configured with a custom rate limiting strategy [flink] via GitHub
• 2026/03/10 Re: [PR] Community blog March 2026 [flink-web] via GitHub
• 2026/03/10 Re: [PR] [FLINK-38371][Connectors / ElasticSearch] Add `sink.retry-on-conflicts` option to Elasticsearch Sink [flink-connector-elasticsearch] via GitHub
• 2026/03/10 Re: [PR] [FLINK-38371][Connectors / ElasticSearch] Add `sink.retry-on-conflicts` option to Elasticsearch Sink [flink-connector-elasticsearch] via GitHub
• 2026/03/10 Re: [PR] [FLINK-39178][table-planner] Support cascaded delta join in planner [flink] via GitHub
• 2026/03/10 [jira] [Closed] (FLINK-39222) Missing licences in HTTP connector files Ferenc Csaky (Jira)
• 2026/03/10 Re: [PR] [FLINK-39222] Add licenses to files and correct Flink version [flink-connector-http] via GitHub
• 2026/03/10 Re: [PR] Community blog March 2026 [flink-web] via GitHub
• 2026/03/10 [jira] [Updated] (FLINK-39207) MySql cdc connector could get stuck in backfill binlog reading after a failover within snapshot phase Cong Cheng (Jira)
• 2026/03/10 Re: [PR] Community blog March 2026 [flink-web] via GitHub
• 2026/03/10 [jira] [Updated] (FLINK-39235) Allow constants to be added to the json response in the HTTP Connector David Radley (Jira)
• 2026/03/10 Re: [PR] [FLINK-39237][Doc] Decouple flink-training links from the Flink branch [flink] via GitHub
• 2026/03/10 [jira] [Updated] (FLINK-39235) Allow constants to be added to the json response in the HTTP Connector David Radley (Jira)
• 2026/03/10 [jira] [Updated] (FLINK-39237) Docs training links should not depend on the Flink release branch ASF GitHub Bot (Jira)
• 2026/03/10 [jira] [Updated] (FLINK-39207) MySql cdc connector could get stuck in backfill binlog reading after a failover within snapshot phase Cong Cheng (Jira)
• 2026/03/10 [PR] [FLINK-39237][Doc] Decouple flink-training links from the Flink branch [flink] via GitHub
• 2026/03/10 Re: [PR] [hotfix] Update weekly CI versions [flink-connector-kafka] via GitHub
• 2026/03/10 [jira] [Updated] (FLINK-39207) MySql cdc connector could get stuck in backfill binlog reading after a failover within snapshot phase Cong Cheng (Jira)
• 2026/03/10 [PR] [FLINK-39200][mysql] Fix mysql cdc could get stuck in backfill binlog reading when reuse snapshot split reader [flink-cdc] via GitHub
• 2026/03/10 [jira] [Comment Edited] (FLINK-39223) IllegalStateException: Failed to send request to coordinator: SchemaChangeRequest vertern (Jira)
• 2026/03/10 [jira] [Commented] (FLINK-39223) IllegalStateException: Failed to send request to coordinator: SchemaChangeRequest vertern (Jira)
• 2026/03/10 [jira] (FLINK-39223) IllegalStateException: Failed to send request to coordinator: SchemaChangeRequest vertern (Jira)
• 2026/03/10 [jira] [Updated] (FLINK-39237) Docs training links should not depend on the Flink release branch Yu Tang (Jira)
• 2026/03/10 Re: [PR] [FLINK-38096] AsyncSinkWriter may hang when configured with a custom rate limiting strategy [flink] via GitHub
• 2026/03/10 Re: [PR] [FLINK-21309][metrics] Add UUID as grouping key for prom pushgateway [flink] via GitHub
• 2026/03/10 Re: [PR] [FLINK-21309][metrics] Add UUID as grouping key for prom pushgateway [flink] via GitHub
• 2026/03/10 Re: [PR] [FLINK-21309][metrics] Add UUID as grouping key for prom pushgateway [flink] via GitHub
• 2026/03/10 [jira] [Created] (FLINK-39237) Docs training links should not depend on the Flink release branch Yu Tang (Jira)
• 2026/03/10 Re: [PR] [FLINK-39232] Modify Transform rules applying logic to first match only [flink-cdc] via GitHub
• 2026/03/10 [jira] [Commented] (FLINK-39030) Support emit-only-on-update mode for CUMULATE window TVF to reduce unnecessary outputs Liu (Jira)
• 2026/03/10 [jira] [Created] (FLINK-39236) Adapt binary delta join runtime operator to structure of cascade delta join Xuyang Zhong (Jira)
• 2026/03/10 [jira] [Commented] (FLINK-39050) Support configurable handling strategy for null rowtime field in watermark generation Liu (Jira)
• 2026/03/10 [jira] [Commented] (FLINK-39064) Add built-in REGEXP_SPLIT function to split string by regular expression pattern Liu (Jira)
• 2026/03/10 [jira] [Commented] (FLINK-38988) Support INET_ATON and INET_NTOA functions for IP address conversion Liu (Jira)
• 2026/03/10 [jira] [Commented] (FLINK-38990) Support configurable initial delay for first checkpoint trigger Liu (Jira)
• 2026/03/10 Re: [PR] [FLINK-38990][Runtime/Checkpointing] Support configurable initial delay for first checkpoint trigger [flink] via GitHub
• 2026/03/10 Re: [PR] [FLINK-32380] Support Java Records with PojoTypeInfo/Serializer [flink] via GitHub
• 2026/03/10 [jira] [Created] (FLINK-39235) add David Radley (Jira)
• 2026/03/10 [jira] [Assigned] (FLINK-39235) add David Radley (Jira)
• 2026/03/10 [jira] [Commented] (FLINK-38196) IndexOutOfBoundsException when processing PostgreSQL tables with numeric(0) fields in Flink CDC Hongshun Wang (Jira)
• 2026/03/10 Re: [PR] [FLINK-38962][connectors/opensearch] Add OpenSearch 3.x support with opensearch-java client [flink-connector-opensearch] via GitHub
• 2026/03/10 Re: [PR] [FLINK-39081] Add ARTIFACT keyword option in CREATE FUNCTION's USING clause [flink] via GitHub
• 2026/03/10 Re: [PR] [FLINK-38822] Extend URL_DECODE with optional recursive decoding [flink] via GitHub
• 2026/03/10 Re: [PR] [FLINK-39200][mysql] Skip insert/update/delete binlog deserialization of unsubscribed tables in MySql CDC binary log client. [flink-cdc] via GitHub

• Earlier messages
• Later messages