issues  

Messages by Date

• 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
• 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
• 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
• 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
• 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
• 2026/03/10 [jira] [Updated] (FLINK-39232) CDC Transform matches first matching rule and deprecate partial filtering ASF GitHub Bot (Jira)
• 2026/03/10 Re: [PR] [FLINK-39016][Runtime/REST] Add configurable TTL for ExecutionGraph cache independent of web refresh interval [flink] via GitHub
• 2026/03/10 [PR] [FLINK-39232] Modify Transform rules applying logic to first match only [flink-cdc] via GitHub
• 2026/03/10 [jira] [Created] (FLINK-39234) KafkaWriterFaultToleranceITCase flakiness due to NotLeaderOrFollowerException Efrat Levitan (Jira)
• 2026/03/10 Re: [PR] [FLINK-39174][table-planner] Support lookup join after delta join [flink] via GitHub
• 2026/03/10 [jira] [Commented] (FLINK-39051) Support APPROX_COUNT_DISTINCT aggregate function in streaming mode with Window TVF Liu (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 [jira] [Updated] (FLINK-39233) Support cascaded delta join in runtime Xuyang Zhong (Jira)
• 2026/03/10 Re: [PR] [FLINK-39065][Formats (JSON, Avro, Parquet, ORC, SequenceFile)] Support additional CsvParser.Feature options for CSV format deserialization [flink] via GitHub
• 2026/03/10 Re: [PR] [FLINK-38244][hotfix] Fix the full snapshot phase, the field case is adjusted based on isTableIdCaseInsensitive [flink-cdc] via GitHub
• 2026/03/10 Re: [PR] [FLINK-38592] Initial Native Flink S3 FileSystem [flink] via GitHub
• 2026/03/10 [jira] [Updated] (FLINK-39233) Support cascaded delta join in runtime Xuyang Zhong (Jira)
• 2026/03/10 [jira] [Updated] (FLINK-39233) Support cascaded delta join in runtime Xuyang Zhong (Jira)
• 2026/03/10 [jira] [Created] (FLINK-39233) Support cascaded delta join in runtime Xuyang Zhong (Jira)
• 2026/03/10 Re: [PR] [FLINK-39195][Table SQL/API] ObjectPath should implement Comparable [flink] via GitHub
• 2026/03/10 Re: [PR] [FLINK-38959][pipeline-connector][postgres]Added support for schema change in the postgres pipeline connector [flink-cdc] via GitHub
• 2026/03/10 [jira] [Created] (FLINK-39232) CDC Transform matches first matching rule and deprecate partial filtering Xiqian Yu (Jira)
• 2026/03/10 Re: [PR] [FLINK-38959][pipeline-connector][postgres]Added support for schema change in the postgres pipeline connector [flink-cdc] via GitHub
• 2026/03/10 Re: [PR] [FLINK-38959][pipeline-connector][postgres]Added support for schema change in the postgres pipeline connector [flink-cdc] via GitHub
• 2026/03/10 Re: [PR] [FLINK-38959][pipeline-connector][postgres]Added support for schema change in the postgres pipeline connector [flink-cdc] via GitHub
• 2026/03/10 Re: [PR] [infra] Use GHA workflow triggers to run pull request labeler workflow [flink-agents] via GitHub
• 2026/03/10 [PR] [infra] Use GHA workflow triggers to run pull request labeler workflow [flink-agents] via GitHub
• 2026/03/10 [I] [Tech Debt] Fix GitHub Actions security by replacing the pull_request_target trigger in CI workflows [flink-agents] via GitHub
• 2026/03/10 Re: [PR] [FLINK-38218] Fix MySQL CDC binlog split metadata split transmission [flink-cdc] via GitHub
• 2026/03/10 Re: [PR] [FLINK-38831][route] The route configuration supports matching the first one [flink-cdc] via GitHub
• 2026/03/10 Re: [PR] [FLINK-38831][route] The route configuration supports matching the first one [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 [jira] [Resolved] (FLINK-39055) [Iceberg] Support default column values in Iceberg sink connector Yanquan Lv (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-39178][table-planner] Support cascaded delta join in planner [flink] via GitHub
• 2026/03/10 Re: [PR] [FLINK-38831][route] The route configuration supports matching the first one [flink-cdc] via GitHub
• 2026/03/09 Re: [D] Community Sync - 2026 [flink-agents] via GitHub
• 2026/03/09 [jira] [Updated] (FLINK-39228) [starrocks] Escape quoted default/comment literals in DDL ASF GitHub Bot (Jira)
• 2026/03/09 Re: [PR] [FLINK-39228][starrocks] Escape quoted default/comment literals in DDL [flink-cdc] via GitHub
• 2026/03/09 Re: [PR] [FLINK-39055] [Iceberg] Support default column values in Iceberg sink connector [flink-cdc] via GitHub
• 2026/03/09 Re: [PR] [FLINK-38704][metrics] Fix MetricConfig.getString() to handle numeric values [flink] via GitHub
• 2026/03/09 Re: [PR] [FLINK-39178][table-planner] Support cascaded delta join in planner [flink] via GitHub
• 2026/03/09 Re: [PR] [FLINK-38704][metrics] Fix MetricConfig.getString() to handle numeric values [flink] via GitHub
• 2026/03/09 Re: [PR] [FLINK-39178][table-planner] Support cascaded delta join in planner [flink] via GitHub
• 2026/03/09 [jira] [Updated] (FLINK-38218) MySQL CDC source may ignore newly added tables while reading the binlog (scenario 1) Ruan Hang (Jira)
• 2026/03/09 [jira] [Updated] (FLINK-39231) [sqlserver] SqlServerConnectorITCase.testConsumingAllEvents occasional failure Mingliang Zhu (Jira)
• 2026/03/09 [jira] [Commented] (FLINK-38218) MySQL CDC source may ignore newly added tables while reading the binlog (scenario 1) Ruan Hang (Jira)
• 2026/03/09 [jira] [Assigned] (FLINK-38218) MySQL CDC source may ignore newly added tables while reading the binlog (scenario 1) Ruan Hang (Jira)
• 2026/03/09 [PR] [FLINK-39231][test][sqlserver] Fix unstable sqlserver connector test [flink-cdc] via GitHub
• 2026/03/09 [jira] [Updated] (FLINK-39231) [sqlserver] SqlServerConnectorITCase.testConsumingAllEvents occasional failure ASF GitHub Bot (Jira)
• 2026/03/09 [jira] [Created] (FLINK-39231) [sqlserver] SqlServerConnectorITCase.testConsumingAllEvents occasional failure Mingliang Zhu (Jira)
• 2026/03/09 Re: [PR] [FLINK-39178][table-planner] Support cascaded delta join in planner [flink] via GitHub
• 2026/03/09 Re: [PR] [plan] Extract ResourceCache and PythonResourceBridge from AgentPlan [flink-agents] via GitHub
• 2026/03/09 Re: [PR] [plan] Extract ResourceCache and PythonResourceBridge from AgentPlan [flink-agents] via GitHub
• 2026/03/09 Re: [PR] [FLINK-38096] AsyncSinkWriter may hang when configured with a custom rate limiting strategy [flink] via GitHub
• 2026/03/09 Re: [PR] [FLINK-36581][cli] Allow passing Flink configuration by yaml job file [flink-cdc] via GitHub
• 2026/03/09 Re: [PR] [FLINK-36581][cli] Allow passing Flink configuration by yaml job file [flink-cdc] via GitHub
• 2026/03/09 Re: [PR] [FLINK-38831][route] The route configuration supports matching the first one [flink-cdc] via GitHub
• 2026/03/09 Re: [PR] [FLINK-38830][runtime] Handle duplicate AddColumnEvent gracefully to prevent pipeline crashes [flink-cdc] via GitHub
• 2026/03/09 [jira] [Commented] (FLINK-39226) pemja.core.object.PyIterator ClassCastException Dian Fu (Jira)
• 2026/03/09 Re: [PR] [FLINK-38205][format][pb] Discard unknown fields by default [flink] via GitHub
• 2026/03/09 Re: [PR] [FLINK-39055] [Iceberg] Support default column values in Iceberg sink connector [flink-cdc] via GitHub
• 2026/03/09 [jira] [Commented] (FLINK-13856) Reduce the delete file api when the checkpoint is completed Liu (Jira)
• 2026/03/09 Re: [PR] [FLINK-39065][Formats (JSON, Avro, Parquet, ORC, SequenceFile)] Support additional CsvParser.Feature options for CSV format deserialization [flink] via GitHub
• 2026/03/09 [jira] [Comment Edited] (FLINK-37926) Support type casting between variant and constructed type Xuannan Su (Jira)
• 2026/03/09 [jira] [Commented] (FLINK-37926) Support type casting between variant and constructed type Xuannan Su (Jira)
• 2026/03/09 [jira] [Assigned] (FLINK-37926) Support type casting between variant and constructed type Xuannan Su (Jira)
• 2026/03/09 [jira] [Created] (FLINK-39230) CDC Pipeline transform should handle partially-applied filters on UPDATE events Xiqian Yu (Jira)
• 2026/03/09 Re: [PR] [FLINK-39178][table-planner] Support cascaded delta join in planner [flink] via GitHub
• 2026/03/09 Re: [PR] [FLINK-38205][format][pb] Discard unknown fields by default [flink] via GitHub
• 2026/03/09 [jira] [Commented] (FLINK-39002) Could not resolve ResourceManager because of NPE David Anderson (Jira)
• 2026/03/09 [jira] [Commented] (FLINK-38926) FLIP-558: Improvements to SinkUpsertMaterializer and changelog disorder David Anderson (Jira)
• 2026/03/09 Re: [PR] [FLINK-23555] Support common sub-expression elimination in code generation [flink] via GitHub
• 2026/03/09 Re: [PR] [FLINK-38770][runtime] Fix parallelism overrides ignored in Application Mode [flink] via GitHub
• 2026/03/09 Re: [PR] [FLINK-39081] Add ARTIFACT keyword option in CREATE FUNCTION's USING clause [flink] via GitHub
• 2026/03/09 [jira] [Commented] (FLINK-38815) The debug log will print the sensitive information of data security cookie certification in task manager and jobmanager VISHAL B (Jira)
• 2026/03/09 Re: [D] [Feature] Enhance the quickstart experience [flink-agents] via GitHub
• 2026/03/09 [jira] [Closed] (FLINK-17224) Precision of TIME type does not work correctly Timo Walther (Jira)
• 2026/03/09 [jira] [Reopened] (FLINK-17224) Precision of TIME type does not work correctly Timo Walther (Jira)
• 2026/03/09 [jira] [Closed] (FLINK-17224) Precision of TIME type does not work correctly Timo Walther (Jira)
• 2026/03/09 Re: [PR] [FLINK-23555] Support common sub-expression elimination in code generation [flink] via GitHub
• 2026/03/09 [PR] [FLINK-23555] Support common sub-expression elimination in code generation [flink] via GitHub
• 2026/03/09 Re: [PR] [FLINK-38096] AsyncSinkWriter may hang when configured with a custom rate limiting strategy [flink] via GitHub
• 2026/03/09 Re: [PR] [FLINK-38592] Initial Native Flink S3 FileSystem [flink] via GitHub
• 2026/03/09 [PR] [FLINK-38096] AsyncSinkWriter may hang when configured with a custom rate limiting strategy [flink] via GitHub
• 2026/03/09 Re: [PR] [hotfix] Fix grammar [flink-connector-http] via GitHub
• 2026/03/09 Re: [PR] [FLINK-39191][runtime-web] Upgrade monaco-editor to 0.55.1 [flink] via GitHub
• 2026/03/09 Re: [PR] [hotfix] Fix grammar [flink-connector-http] via GitHub
• 2026/03/09 Re: [PR] [hotfix] Fix grammar [flink-connector-http] via GitHub
• 2026/03/09 Re: [PR] [FLINK-38096] AsyncSinkWriter may hang when configured with a custom rate limiting strategy [flink] via GitHub
• 2026/03/09 [PR] [hotfix] Update weekly CI releases [flink-connector-kafka] via GitHub
• 2026/03/09 Re: [PR] [FLINK-39229][test] Migrate tests of flink-protobuf to JUnit5 [flink] via GitHub
• 2026/03/09 [jira] [Commented] (FLINK-39176) Introduce Node Health Management & Quarantine Framework for ResourceManager Zhanghao Chen (Jira)
• 2026/03/09 [jira] [Updated] (FLINK-39229) [JUnit5 Migration] Module: flink-protobuf ASF GitHub Bot (Jira)
• 2026/03/09 [PR] [FLINK-39229][test] Migrate tests of flink-protobuf to JUnit5 [flink] via GitHub
• 2026/03/09 Re: [PR] Community blog March 2026 [flink-web] via GitHub
• 2026/03/09 Re: [PR] Community blog March 2026 [flink-web] via GitHub
• 2026/03/09 Re: [PR] [FLINK-23555] Support common sub-expression elimination in code generation [flink] via GitHub
• 2026/03/09 Re: [PR] Community blog March 2026 [flink-web] via GitHub
• 2026/03/09 Re: [PR] Community blog March 2026 [flink-web] via GitHub
• 2026/03/09 Re: [PR] Community blog March 2026 [flink-web] via GitHub
• 2026/03/09 Re: [PR] Community blog March 2026 [flink-web] via GitHub
• 2026/03/09 Re: [PR] [FLINK-38825] Introduce AsyncBatchFunction and AsyncBatchWaitOperator [flink] via GitHub
• 2026/03/09 Re: [PR] Community blog March 2026 [flink-web] via GitHub
• 2026/03/09 Re: [PR] [FLINK-23555] Support common sub-expression elimination in code generation [flink] via GitHub
• 2026/03/09 Re: [PR] Community blog March 2026 [flink-web] via GitHub
• 2026/03/09 Re: [PR] Community blog March 2026 [flink-web] via GitHub
• 2026/03/09 Re: [PR] Community blog March 2026 [flink-web] via GitHub
• 2026/03/09 [PR] [FLINK-23555] Support common sub-expression elimination in code generation [flink] via GitHub
• 2026/03/09 [jira] [Updated] (FLINK-23555) Improve common subexpression elimination by using local references ASF GitHub Bot (Jira)
• 2026/03/09 Re: [PR] Community blog March 2026 [flink-web] via GitHub
• 2026/03/09 Re: [PR] Community blog March 2026 [flink-web] via GitHub
• 2026/03/09 Re: [PR] [FLINK-38205][format][pb] Discard unknown fields by default [flink] via GitHub
• 2026/03/09 [jira] [Created] (FLINK-39229) [JUnit5 Migration] Module: flink-protobuf Zhanghao Chen (Jira)
• 2026/03/09 [jira] [Commented] (FLINK-39223) IllegalStateException: Failed to send request to coordinator: SchemaChangeRequest vertern (Jira)
• 2026/03/09 Re: [PR] [FLINK-39222] Add licenses to files and correct Flink version [flink-connector-http] via GitHub
• 2026/03/09 Re: [PR] [FLINK-39081] Add ARTIFACT keyword option in CREATE FUNCTION's USING clause [flink] via GitHub
• 2026/03/09 Re: [PR] [FLINK-39055] [Iceberg] Support default column values in Iceberg sink connector [flink-cdc] via GitHub
• 2026/03/09 Re: [PR] [FLINK-39055] [Iceberg] Support default column values in Iceberg sink connector [flink-cdc] via GitHub
• 2026/03/09 Re: [PR] [ci][fix] fix label ci run failed [flink-cdc] via GitHub
• 2026/03/09 Re: [PR] [ci][fix] fix label ci run failed [flink-cdc] via GitHub
• 2026/03/09 Re: [PR] [FLINK-38729] Add support for Flink 2.2.0 [flink-cdc] via GitHub
• 2026/03/09 Re: [PR] [FLINK-38729] Add support for Flink 2.2.0 [flink-cdc] via GitHub
• 2026/03/09 [jira] [Assigned] (FLINK-38815) The debug log will print the sensitive information of data security cookie certification in task manager and jobmanager Matthias Pohl (Jira)
• 2026/03/09 [jira] [Assigned] (FLINK-38815) The debug log will print the sensitive information of data security cookie certification in task manager and jobmanager Matthias Pohl (Jira)
• 2026/03/09 Re: [PR] [ci][fix] fix label ci run failed [flink-cdc] via GitHub
• 2026/03/09 Re: [PR] Community blog March 2026 [flink-web] via GitHub
• 2026/03/09 Re: [PR] [FLINK-21309][metrics] Add UUID as grouping key for prom pushgateway [flink] via GitHub
• 2026/03/09 [jira] [Comment Edited] (FLINK-38815) The debug log will print the sensitive information of data security cookie certification in task manager and jobmanager Matthias Pohl (Jira)
• 2026/03/09 [jira] [Commented] (FLINK-38815) The debug log will print the sensitive information of data security cookie certification in task manager and jobmanager Matthias Pohl (Jira)
• 2026/03/09 Re: [PR] [FLINK-38729] Add support for Flink 2.2.0 [flink-cdc] via GitHub
• 2026/03/09 Re: [PR] [FLINK-39027][pipeline-connector][postgres] Support DDL for postgres pipeline connector [flink-cdc] via GitHub
• 2026/03/09 Re: [PR] [FLINK-39027][pipeline-connector][postgres] Support DDL for postgres pipeline connector [flink-cdc] via GitHub
• 2026/03/09 Re: [PR] [FLINK-39055] [Iceberg] Support default column values in Iceberg sink connector [flink-cdc] via GitHub
• 2026/03/09 Re: [PR] [Flink-38911][cdc connector mysql] mysql-cdc-connector datastream support scan.binlog.newly-added-table.enabled [flink-cdc] via GitHub
• 2026/03/09 Re: [PR] [FLINK-38205][format][pb] Discard unknown fields by default [flink] via GitHub
• 2026/03/09 Re: [PR] [FLINK-38205][format][pb] Discard unknown fields by default [flink] via GitHub
• 2026/03/09 [jira] [Created] (FLINK-39228) [starrocks] Escape quoted default/comment literals in DDL Mingliang Zhu (Jira)
• 2026/03/09 [jira] [Comment Edited] (FLINK-39223) IllegalStateException: Failed to send request to coordinator: SchemaChangeRequest vertern (Jira)
• 2026/03/09 [jira] [Commented] (FLINK-39223) IllegalStateException: Failed to send request to coordinator: SchemaChangeRequest vertern (Jira)
• 2026/03/09 [PR] [starrocks] Escape quoted default/comment literals in DDL [flink-cdc] via GitHub
• 2026/03/09 [jira] [Updated] (FLINK-39223) IllegalStateException: Failed to send request to coordinator: SchemaChangeRequest vertern (Jira)
• 2026/03/09 [jira] [Commented] (FLINK-39223) IllegalStateException: Failed to send request to coordinator: SchemaChangeRequest vertern (Jira)
• 2026/03/09 [jira] [Updated] (FLINK-39223) IllegalStateException: Failed to send request to coordinator: SchemaChangeRequest vertern (Jira)
• 2026/03/08 Re: [PR] [FLINK-38721] Support vector search for es connector. [flink-connector-elasticsearch] via GitHub
• 2026/03/08 [jira] [Resolved] (FLINK-38247) MySqlChunkSplitter may continuously generate splits when using BIGINT UNSIGNED as primary key Yanquan Lv (Jira)
• 2026/03/08 Re: [PR] [FLINK-38247] Handle BIGINT UNSIGNED overflow in PreparedStatement [flink-cdc] via GitHub
• 2026/03/08 [jira] [Created] (FLINK-39227) FLIP-566 Introduce a new IMMUTABLE columns constraint Xuyang Zhong (Jira)
• 2026/03/08 [jira] [Updated] (FLINK-39226) pemja.core.object.PyIterator ClassCastException Shuyi Chen (Jira)
• 2026/03/08 [jira] [Updated] (FLINK-39226) pemja.core.object.PyIterator ClassCastException Shuyi Chen (Jira)
• 2026/03/08 [jira] [Updated] (FLINK-39226) pemja.core.object.PyIterator ClassCastException Shuyi Chen (Jira)
• 2026/03/08 [jira] [Created] (FLINK-39226) pemja.core.object.PyIterator ClassCastException Shuyi Chen (Jira)
• 2026/03/08 Re: [PR] [FLINK-39055] [Iceberg] Support default column values in Iceberg sink connector [flink-cdc] via GitHub
• 2026/03/08 Re: [PR] [FLINK-38729] Add support for Flink 2.2.0 [flink-cdc] via GitHub
• 2026/03/08 Re: [PR] [minor][docs][style] Update documentation link and improve code style [flink-cdc] via GitHub
• 2026/03/08 [jira] [Created] (FLINK-39225) Add retry with default value fallback for triton inference failures featzhang (Jira)
• 2026/03/08 [jira] [Updated] (FLINK-38857) Introduce a Triton inference module for batch-oriented AI inference featzhang (Jira)
• 2026/03/08 Re: [D] [Feature] Per-Event-Type Configurable Log Levels for Event Log [flink-agents] via GitHub
• 2026/03/08 Re: [D] [Feature] Per-Event-Type Configurable Log Levels for Event Log [flink-agents] via GitHub
• 2026/03/08 [jira] [Created] (FLINK-39224) Support PostgreSQL jsonb type CHANHAE OH (Jira)
• 2026/03/08 Re: [PR] [FLINK-39055] [Iceberg] Support default column values in Iceberg sink connector [flink-cdc] via GitHub
• 2026/03/08 Re: [PR] [FLINK-39055] [Iceberg] Support default column values in Iceberg sink connector [flink-cdc] via GitHub
• 2026/03/08 [jira] [Commented] (FLINK-29855) UDF randomly processed input data twice huyuliang (Jira)
• 2026/03/08 Re: [PR] [FLINK-38729] Add support for Flink 2.2.0 [flink-cdc] via GitHub
• 2026/03/08 [jira] [Created] (FLINK-39223) IllegalStateException: Failed to send request to coordinator: SchemaChangeRequest vertern (Jira)
• 2026/03/08 [jira] [Updated] (FLINK-39223) IllegalStateException: Failed to send request to coordinator: SchemaChangeRequest vertern (Jira)
• 2026/03/08 [jira] [Resolved] (FLINK-37292) The Flink-Kubernetes dependency embedded in the packaging of flink-cdc-dist is incompatible with Flink 1.20. Yanquan Lv (Jira)
• 2026/03/08 Re: [PR] [FLINK-37292] [cdc] Remove the flink-kubernetes dependencies during the packaging of flink-cdc-dist [flink-cdc] via GitHub
• 2026/03/08 [jira] [Comment Edited] (FLINK-38857) Introduce a Triton inference module under flink-models for batch-oriented AI inference Dian Fu (Jira)
• 2026/03/08 [jira] [Comment Edited] (FLINK-38857) Introduce a Triton inference module under flink-models for batch-oriented AI inference Dian Fu (Jira)
• 2026/03/08 Re: [PR] [MINOR] Update starrocks.md [flink-cdc] via GitHub
• 2026/03/08 [jira] [Resolved] (FLINK-38160) StarRocks Pipeline connector supports TIME/BINARY/VARBINARY type mapping Yanquan Lv (Jira)

• Earlier messages
• Later messages