issues  

Messages by Date

• 2025/12/17 Re: [PR] [Feature][Integration][Java] add ElasticsearchVectorStore in Java [flink-agents] via GitHub
• 2025/12/17 [jira] [Updated] (FLINK-38814) Kinesis Source in EFO - idle consumer on subscription failure Juliusz Nadberezny (Jira)
• 2025/12/17 [PR] [Flink-388814][Connector/Kinesis] Kinesis Source in EFO - Fix idle consumer on subscription failure [flink-connector-aws] via GitHub
• 2025/12/17 Re: [PR] [FLINK-34088] [hotfix] fix the problems with special table name characters of postgres and oracle  and sqlserver. [flink-connector-jdbc] via GitHub
• 2025/12/17 [jira] [Updated] (FLINK-38814) Kinesis Source in EFO - idle consumer on subscription failure Juliusz Nadberezny (Jira)
• 2025/12/17 Re: [PR] [FLINK-34257][core] Update Flink YAML Parser to Support YAML 1.2 Specification. [flink] via GitHub
• 2025/12/17 [jira] [Updated] (FLINK-38814) Kinesis Source in EFO - idle consumer on subscription failure Juliusz Nadberezny (Jira)
• 2025/12/17 [jira] [Updated] (FLINK-38814) Kinesis Source in EFO - idle consumer on subscription failure Juliusz Nadberezny (Jira)
• 2025/12/17 [jira] [Created] (FLINK-38814) Kinesis Source in EFO - idle consumer on subscription failure Juliusz Nadberezny (Jira)
• 2025/12/17 Re: [PR] [Feature][Integration][Java] add ElasticsearchVectorStore in Java [flink-agents] via GitHub
• 2025/12/17 [jira] [Assigned] (FLINK-38811) Translate async function doc to Chinese Shengkai Fang (Jira)
• 2025/12/17 [jira] [Closed] (FLINK-38811) Translate async function doc to Chinese Shengkai Fang (Jira)
• 2025/12/17 [jira] [Commented] (FLINK-38811) Translate async function doc to Chinese Shengkai Fang (Jira)
• 2025/12/17 Re: [PR] [FLINK-38811] translate async scalar function doc to Chinese [flink] via GitHub
• 2025/12/16 [jira] [Updated] (FLINK-38801) Add Spotless plugin with Google AOSP style for flink benchmark repository ASF GitHub Bot (Jira)
• 2025/12/16 [PR] [FLINK-38801][benchmark] Add Spotless and checkstyle plugins with Google AOSP style for flink benchmark repository [flink-benchmarks] via GitHub
• 2025/12/16 Re: [PR] [Feature][runtime] Support the use of Java ChatModel in Python [flink-agents] via GitHub
• 2025/12/16 Re: [I] [Bug] RescalingITCase fails due to data loss [flink-agents] via GitHub
• 2025/12/16 Re: [I] [Bug] RescalingITCase fails due to data loss [flink-agents] via GitHub
• 2025/12/16 Re: [PR] [Feature][Java] Add MCP support in Java [flink-agents] via GitHub
• 2025/12/16 Re: [PR] [runtime] Remove userCodeClassLoader field for ActionTask to fix can't be serialized to state. [flink-agents] via GitHub
• 2025/12/16 Re: [PR] [Feature][Java] Add MCP support in Java [flink-agents] via GitHub
• 2025/12/16 Re: [PR] [FLINK-37811][Build/Shaded] Update Curator to 5.8.0 [flink-shaded] via GitHub
• 2025/12/16 [jira] [Closed] (FLINK-38574) Avoid reusing re-uploaded sst files when checkpoint notification is delayed Roman Khachatryan (Jira)
• 2025/12/16 [jira] [Commented] (FLINK-38574) Avoid reusing re-uploaded sst files when checkpoint notification is delayed Roman Khachatryan (Jira)
• 2025/12/16 Re: [PR] [BP-1.19][FLINK-38574][checkpoint] Avoid reusing re-uploaded sst files when checkpoint notification is delayed [flink] via GitHub
• 2025/12/16 Re: [PR] [BP-2.0][FLINK-38574][checkpoint] Avoid reusing re-uploaded sst files when checkpoint notification is delayed [flink] via GitHub
• 2025/12/16 Re: [PR] [BP-2.1][FLINK-38574][checkpoint] Avoid reusing re-uploaded sst files when checkpoint notification is delayed [flink] via GitHub
• 2025/12/16 [jira] [Updated] (FLINK-38813) Enable Flink CDC connectors to emit Debezium heartbeat events to downstream consumers Tejansh Rana (Jira)
• 2025/12/16 [jira] [Updated] (FLINK-38813) Enable Flink CDC connectors to emit Debezium heartbeat events to downstream consumers ASF GitHub Bot (Jira)
• 2025/12/16 [PR] [PROPOSAL][FLINK-38813] : Support for emitting heartbeat events [flink-cdc] via GitHub
• 2025/12/16 [jira] [Commented] (FLINK-38049) UpgradeMode falls back to last-state mode on HA resubmission even for stateless Lucas Borges (Jira)
• 2025/12/16 [jira] [Updated] (FLINK-38813) Enable Flink CDC connector to emit Debezium heartbeat events to downstream consumers Tejansh Rana (Jira)
• 2025/12/16 [jira] [Updated] (FLINK-38813) Enable Flink CDC connectors to emit Debezium heartbeat events to downstream consumers Tejansh Rana (Jira)
• 2025/12/16 [jira] [Created] (FLINK-38813) Enable Flink CDC connector to emit Debezium heartbeat events to downstream consumers Tejansh Rana (Jira)
• 2025/12/16 Re: [PR] [FLINK-38807][state] Add state SQL metadata based type inference [flink] via GitHub
• 2025/12/16 [jira] [Resolved] (FLINK-38802) DDL with duplicated keys in table options should not fail Sergey Nuyanzin (Jira)
• 2025/12/16 [jira] [Commented] (FLINK-38802) DDL with duplicated keys in table options should not fail Sergey Nuyanzin (Jira)
• 2025/12/16 [jira] [Updated] (FLINK-38802) DDL with duplicated keys in table options should not fail Sergey Nuyanzin (Jira)
• 2025/12/16 [jira] [Updated] (FLINK-38802) DDL with duplicated keys in table options should not fail Sergey Nuyanzin (Jira)
• 2025/12/16 Re: [PR] [FLINK-38802][table] DDL with duplicated keys in table options should not fail [flink] via GitHub
• 2025/12/16 Re: [PR] [Feature][runtime] Support the use of Java ChatModel in Python [flink-agents] via GitHub
• 2025/12/16 [jira] [Updated] (FLINK-38812) Log PYFLINK_CYTHON_ENABLED to show whether cython optimization is enabled Liu (Jira)
• 2025/12/16 [jira] [Updated] (FLINK-38812) Log PYFLINK_CYTHON_ENABLED to show whether cython optimization is enabled Liu (Jira)
• 2025/12/16 [jira] [Created] (FLINK-38812) Log PYFLINK_CYTHON_ENABLED to show whether cython optimization is enabled Liu (Jira)
• 2025/12/16 [jira] [Updated] (FLINK-38812) Log PYFLINK_CYTHON_ENABLED to show whether cython optimization is enabled Liu (Jira)
• 2025/12/16 Re: [PR] [FLINK-38048] Update java version and move parent pom to v1.2.0 [flink-connector-shared-utils] via GitHub
• 2025/12/16 Re: [PR] [FLINK-38048] Update java version and move parent pom to v1.2.0 [flink-connector-shared-utils] via GitHub
• 2025/12/16 Re: [PR] [FLINK-38181] Fix code generation for primitive type casting and improve cast consistency across compile-time and runtime paths [flink] via GitHub
• 2025/12/16 Re: [PR] [FLINK-38802][table] DDL with duplicated keys in table options should not fail [flink] via GitHub
• 2025/12/16 Re: [PR] [FLINK-38802][table] DDL with duplicated keys in table options should not fail [flink] via GitHub
• 2025/12/16 [I] [Feature] [runtime] Support batched summarization for long-term memory. [flink-agents] via GitHub
• 2025/12/16 Re: [PR] [Feature][Java] Add MCP support in Java [flink-agents] via GitHub
• 2025/12/16 Re: [PR] [Feature][runtime] Support the use of Java ChatModel in Python [flink-agents] via GitHub
• 2025/12/16 Re: [PR] [FLINK-38802][table] DDL with duplicated keys in table options should fail while validation [flink] via GitHub
• 2025/12/16 Re: [PR] [FLINK-38802][table] DDL with duplicated keys in table options should not fail [flink] via GitHub
• 2025/12/16 Re: [PR] [FLINK-38802][table] DDL with duplicated keys in table options should not fail [flink] via GitHub
• 2025/12/16 Re: [PR] [FLINK-38802][table] DDL with duplicated keys in table options should fail while validation [flink] via GitHub
• 2025/12/16 Re: [PR] [FLINK-38802][table] DDL with duplicated keys in table options should not fail [flink] via GitHub
• 2025/12/16 Re: [PR] [FLINK-38802][table] DDL with duplicated keys in table options should not fail [flink] via GitHub
• 2025/12/16 [PR] [FLINK-38802][table] DDL with duplicated keys in table options should not fail [flink] via GitHub
• 2025/12/16 Re: [PR] [Feature][runtime] Support the use of Java ChatModel in Python [flink-agents] via GitHub
• 2025/12/16 Re: [PR] [Feature][runtime] Support the use of Java ChatModel in Python [flink-agents] via GitHub
• 2025/12/16 [jira] [Commented] (FLINK-36609) Protobuf Format not support proto3 Hongshun Wang (Jira)
• 2025/12/16 Re: [PR] [FLINK-38807][state] Add state SQL metadata based type inference [flink] via GitHub
• 2025/12/15 Re: [PR] Flink Version upgrade 2.3-SNAPSHOT [flink-agents] via GitHub
• 2025/12/15 Re: [PR] [FLINK-38806] Fix post-transform converters ineffective without projection or filter rules [flink-cdc] via GitHub
• 2025/12/15 [jira] [Commented] (FLINK-36609) Protobuf Format not support proto3 Hongshun Wang (Jira)
• 2025/12/15 Re: [PR] [api][runtime] Introduce long-term memory in python [flink-agents] via GitHub
• 2025/12/15 Re: [PR] Add Hudi sink connector support [flink-cdc] via GitHub
• 2025/12/15 Re: [PR] [Feature][runtime] Support the use of Java ChatModel in Python [flink-agents] via GitHub
• 2025/12/15 Re: [PR] [Feature][runtime] Support the use of Java ChatModel in Python [flink-agents] via GitHub
• 2025/12/15 [jira] [Closed] (FLINK-38757) Introduce the base class for application Zhu Zhu (Jira)
• 2025/12/15 Re: [PR] [FLINK-38757][runtime] Introduce the base class for application [flink] via GitHub
• 2025/12/15 Re: [PR] [hotfix] Support passing arbitrary database options to JDBC Catalog [flink-connector-jdbc] via GitHub
• 2025/12/15 Re: [PR] [FLINK-37275][pipeline-connector/mysql] MySQL source connector supports using the base module's source metric statistics [flink-cdc] via GitHub
• 2025/12/15 Re: [PR] [FLINK-37275][pipeline-connector/mysql] MySQL source connector supports using the base module's source metric statistics [flink-cdc] via GitHub
• 2025/12/15 Re: [PR] [FLINK-38811] translate async scalar function doc to Chinese [flink] via GitHub
• 2025/12/15 [jira] [Updated] (FLINK-38811) Translate async function doc to Chinese ASF GitHub Bot (Jira)
• 2025/12/15 [PR] [FLINK-38811] translate async scalar function doc to Chinese [flink] via GitHub
• 2025/12/15 [jira] [Created] (FLINK-38811) Translate async function doc to Chinese Hao Li (Jira)
• 2025/12/15 Re: [PR] [hotfix] Adapt supported Python versions to Flink 1.20 [flink-connector-aws] via GitHub
• 2025/12/15 [jira] [Resolved] (FLINK-38776) Incorrect auxiliary group field names Sergey Nuyanzin (Jira)
• 2025/12/15 [jira] [Commented] (FLINK-38776) Incorrect auxiliary group field names Sergey Nuyanzin (Jira)
• 2025/12/15 Re: [PR] [FLINK-38776][table] Fix incorrect auxiliary group field names [flink] via GitHub
• 2025/12/15 [jira] [Resolved] (FLINK-38791) Add support for ALTER MATERIALIZED TABLE MODIFY Sergey Nuyanzin (Jira)
• 2025/12/15 [jira] [Commented] (FLINK-38791) Add support for ALTER MATERIALIZED TABLE MODIFY Sergey Nuyanzin (Jira)
• 2025/12/15 Re: [PR] [FLINK-38791][table] Add support for `ALTER MATERIALIZED TABLE MODIFY` [flink] via GitHub
• 2025/12/15 Re: [PR] [FLINK-38791][table] Add support for `ALTER MATERIALIZED TABLE MODIFY` [flink] via GitHub
• 2025/12/15 Re: [PR] [FLINK-38799][runtime] Rename `LoadingWeight` to `ResourceUnitCount` [flink] via GitHub
• 2025/12/15 Re: [PR] [FLINK-38807][state] Add state SQL metadata based type inference [flink] via GitHub
• 2025/12/15 Re: [PR] [FLINK-38810] Use splittable timers in Interval Join [flink] via GitHub
• 2025/12/15 [jira] [Updated] (FLINK-38810) Use splittable timers in Interval Join ASF GitHub Bot (Jira)
• 2025/12/15 [PR] [FLINK-38810] Use splittable timers in Interval Join [flink] via GitHub
• 2025/12/15 [jira] [Updated] (FLINK-38810) Use splittable timers in Interval Join Roman Khachatryan (Jira)
• 2025/12/15 [jira] [Created] (FLINK-38810) Use splittable timers in Interval Join Roman Khachatryan (Jira)
• 2025/12/15 [jira] [Updated] (FLINK-38810) Use splittable timers in Interval Join Roman Khachatryan (Jira)
• 2025/12/15 Re: [PR] [FLINK-38733] Add new SplitterEnumerator on JdbcSource [flink-connector-jdbc] via GitHub
• 2025/12/15 [jira] [Commented] (FLINK-38225) GSBlobStorageImpl needs to add precondition check to make 503 retryable Oleksandr Nitavskyi (Jira)
• 2025/12/15 Re: [PR] [BP-1.19][FLINK-38574][checkpoint] Avoid reusing re-uploaded sst files when checkpoint notification is delayed [flink] via GitHub
• 2025/12/15 Re: [PR] [BP-2.0][FLINK-38574][checkpoint] Avoid reusing re-uploaded sst files when checkpoint notification is delayed [flink] via GitHub
• 2025/12/15 Re: [PR] [BP-2.1][FLINK-38574][checkpoint] Avoid reusing re-uploaded sst files when checkpoint notification is delayed [flink] via GitHub
• 2025/12/15 [jira] [Updated] (FLINK-38574) Avoid reusing re-uploaded sst files when checkpoint notification is delayed Roman Khachatryan (Jira)
• 2025/12/15 [jira] [Reopened] (FLINK-38574) Avoid reusing re-uploaded sst files when checkpoint notification is delayed Roman Khachatryan (Jira)
• 2025/12/15 [PR] [BP-1.19][FLINK-38574][checkpoint] Avoid reusing re-uploaded sst files when checkpoint notification is delayed [flink] via GitHub
• 2025/12/15 [PR] [BP-2.0][FLINK-38574][checkpoint] Avoid reusing re-uploaded sst files when checkpoint notification is delayed [flink] via GitHub
• 2025/12/15 Re: [PR] [FLINK-38574][checkpoint] Avoid reusing re-uploaded sst files when checkpoint notification is delayed [flink] via GitHub
• 2025/12/15 [PR] [FLINK-38574][checkpoint] Avoid reusing re-uploaded sst files when checkpoint notification is delayed [flink] via GitHub
• 2025/12/15 [jira] [Commented] (FLINK-38486) Harden shutdown of DefaultExpressionEvaluator Roman Khachatryan (Jira)
• 2025/12/15 [jira] [Closed] (FLINK-38486) Harden shutdown of DefaultExpressionEvaluator Roman Khachatryan (Jira)
• 2025/12/15 Re: [PR] [BP-2.1][FLINK-38486] Harden shutdown of system UDFs [flink] via GitHub
• 2025/12/15 Re: [PR] [BP-2.1][FLINK-38486] Harden shutdown of system UDFs [flink] via GitHub
• 2025/12/15 Re: [PR] [BP-2.0][FLINK-38486] Harden shutdown of system UDFs [flink] via GitHub
• 2025/12/15 Re: [PR] [BP-2.0][FLINK-38486] Harden shutdown of system UDFs [flink] via GitHub
• 2025/12/15 Re: [PR] [BP-2.0][FLINK-38486] Harden shutdown of system UDFs [flink] via GitHub
• 2025/12/15 [jira] [Closed] (FLINK-38765) Sink Upsert Materializer does not work with metadata columns Dawid Wysakowicz (Jira)
• 2025/12/15 Re: [PR] [FLINK-38765] Fix persisted metadata handling in sink [flink] via GitHub
• 2025/12/15 Re: [PR] [FLINK-38809][Tests] Upgrade Testcontainers to 2.0.2 [flink] via GitHub
• 2025/12/15 Re: [PR] [hotfix] Adapt supported Python versions to Flink 1.20 [flink-connector-aws] via GitHub
• 2025/12/15 [PR] [hotfix] Adapt supported Python versions to Flink 1.20 [flink-connector-aws] via GitHub
• 2025/12/15 Re: [PR] [FLINK-38764] Upgrade lz4 to 1.8.1 due to security vulnerability [flink] via GitHub
• 2025/12/15 Re: [PR] [BP-2.1][FLINK-38486] Harden shutdown of system UDFs [flink] via GitHub
• 2025/12/15 Re: [PR] [BP-2.0][FLINK-38486] Harden shutdown of system UDFs [flink] via GitHub
• 2025/12/15 Re: [PR] [FLINK-38809][Tests] Upgrade Testcontainers to 2.0.2 [flink] via GitHub
• 2025/12/15 Re: [PR] [FLINK-38791][table] Add support for `ALTER MATERIALIZED TABLE MODIFY` [flink] via GitHub
• 2025/12/15 Re: [PR] [FLINK-38791][table] Add support for `ALTER MATERIALIZED TABLE MODIFY` [flink] via GitHub
• 2025/12/15 Re: [PR] [FLINK-38413] Adding support for append only tables to MySQL Pipeline connector [flink-cdc] via GitHub
• 2025/12/15 Re: [PR] [FLINK-38809][Tests] Upgrade Testcontainers to 2.0.2 [flink] via GitHub
• 2025/12/15 Re: [PR] [FLINK-38765] Fix persisted metadata handling in sink [flink] via GitHub
• 2025/12/15 Re: [PR] [FLINK-38807][state] Add state SQL metadata based type inference [flink] via GitHub
• 2025/12/15 Re: [PR] [FLINK-38791][table] Add support for `ALTER MATERIALIZED TABLE MODIFY` [flink] via GitHub
• 2025/12/15 [jira] [Updated] (FLINK-38809) Update testcontainers to 2.0.2 ASF GitHub Bot (Jira)
• 2025/12/15 [PR] [FLINK-38809][Tests] Upgrade Testcontainers to 2.0.2 [flink] via GitHub
• 2025/12/15 Re: [PR] [FLINK-38791][table] Add support for `ALTER MATERIALIZED TABLE MODIFY` [flink] via GitHub
• 2025/12/15 [jira] [Created] (FLINK-38809) Update testcontainers to 2.0.2 Martijn Visser (Jira)
• 2025/12/15 [jira] [Resolved] (FLINK-37971) SQL hints are dropped when combining multiple SELECT into a single source Maximilian Michels (Jira)
• 2025/12/15 Re: [PR] [backport][FLINK-36026][table] Options from `OPTIONS` hint should be present in compiled plan [flink] via GitHub
• 2025/12/15 Re: [PR] [backport][FLINK-36026][table] Options from `OPTIONS` hint should be present in compiled plan [flink] via GitHub
• 2025/12/15 Re: [PR] [FLINK-38807][state] Add state SQL metadata based type inference [flink] via GitHub
• 2025/12/15 Re: [PR] [FLINK-38807][state] Add state SQL metadata based type inference [flink] via GitHub
• 2025/12/15 Re: [PR] [BP-2.0][FLINK-38486] Harden shutdown of system UDFs [flink] via GitHub
• 2025/12/14 Re: [PR] [Feature][runtime] Support the use of Java ChatModel in Python [flink-agents] via GitHub
• 2025/12/14 Re: [PR] [FLINK-38757][runtime] Introduce the base class for application [flink] via GitHub
• 2025/12/14 Re: [PR] [FLINK-38757][runtime] Introduce the base class for application [flink] via GitHub
• 2025/12/14 Re: [PR] [FLINK-38757][runtime] Introduce the base class for application [flink] via GitHub
• 2025/12/14 [jira] [Closed] (FLINK-37627) Restarting from a checkpoint/savepoint which coincides with shard split causes data loss Ferenc Csaky (Jira)
• 2025/12/14 Re: [PR] [FLINK-37627][BugFix][Connectors/Kinesis] Restarting from a checkpoint/savepoint which coincides with shard split causes data loss [flink-connector-aws] via GitHub
• 2025/12/14 Re: [PR] [FLINK-37627][BugFix][Connectors/Kinesis] Restarting from a checkpoint/savepoint which coincides with shard split causes data loss [flink-connector-aws] via GitHub
• 2025/12/14 Re: [PR] [FLINK-37627][BugFix][Connectors/Kinesis] Restarting from a checkpoint/savepoint which coincides with shard split causes data loss [flink-connector-aws] via GitHub
• 2025/12/14 [jira] [Updated] (FLINK-38808) Support partition transforms in Iceberg sink ASF GitHub Bot (Jira)
• 2025/12/14 [PR] [FLINK-38808][pipeline-connector][iceberg] Support partition transforms in Iceberg sink [flink-cdc] via GitHub
• 2025/12/14 [jira] [Created] (FLINK-38808) Support partition transforms in Iceberg sink ChaoFang (Jira)
• 2025/12/14 [jira] [Commented] (FLINK-31655) Adaptive Channel selection for partitioner RocMarshal (Jira)
• 2025/12/14 Re: [PR] Implement comma-separated parsing for chunk key columns [flink-cdc] via GitHub
• 2025/12/14 Re: [PR] [hotfix] Support passing arbitrary database options to JDBC Catalog [flink-connector-jdbc] via GitHub
• 2025/12/14 Re: [PR] [FLINK-36796][pipeline-connector][oracle]add oracle pipeline connector. [flink-cdc] via GitHub
• 2025/12/14 Re: [PR] [FLINK-36796][pipeline-connector][oracle]add oracle pipeline connector. [flink-cdc] via GitHub
• 2025/12/14 [jira] [Resolved] (FLINK-38797) PyFlink CsvSchemaBuilder.set_null_value method missing return self Dian Fu (Jira)
• 2025/12/14 [jira] [Assigned] (FLINK-38797) PyFlink CsvSchemaBuilder.set_null_value method missing return self Dian Fu (Jira)
• 2025/12/14 Re: [PR] [FLINK-38797][python] Fixed PyFlink issue CsvSchemaBuilder.set_null_value missing return self [flink] via GitHub
• 2025/12/14 Re: [PR] [FLINK-38797][python] Fixed PyFlink issue CsvSchemaBuilder.set_null_value missing return self [flink] via GitHub
• 2025/12/14 Re: [PR] [FLINK-37855-][cdc-connector-mysql] Reduce the time cost in MySqlSchemaUtils#listTables [flink-cdc] via GitHub
• 2025/12/14 Re: [PR] [FLINK-37855-][cdc-connector-mysql] Reduce the time cost in MySqlSchemaUtils#listTables [flink-cdc] via GitHub
• 2025/12/14 Re: [PR] [FLINK-37627][BugFix][Connectors/Kinesis] Restarting from a checkpoint/savepoint which coincides with shard split causes data loss [flink-connector-aws] via GitHub
• 2025/12/14 Re: [PR] [FLINK-38733] Add new SplitterEnumerator on JdbcSource [flink-connector-jdbc] via GitHub
• 2025/12/14 Re: [PR] [hotfix] Support passing arbitrary database options to JDBC Catalog [flink-connector-jdbc] via GitHub
• 2025/12/13 Re: [PR] Flink Version upgrade 2.3-SNAPSHOT [flink-agents] via GitHub
• 2025/12/13 [PR] Flink Version upgrade 2.3-SNAPSHOT [flink-agents] via GitHub
• 2025/12/13 Re: [PR] Reuse byte array buffer in BlobServerConnection::run [flink] via GitHub
• 2025/12/13 Re: [PR] [FLINK-36842] FlinkPipelineComposer allows injecting StreamExecutionEnvironment [flink-cdc] via GitHub
• 2025/12/13 Re: [PR] [FLINK-36842] FlinkPipelineComposer allows injecting StreamExecutionEnvironment [flink-cdc] via GitHub
• 2025/12/13 Re: [PR] [FLINK-37677][cdc-common][cdc-runtime] Handle Exclusion of `create.table` Events in Flink CDC Schema Evolution [flink-cdc] via GitHub
• 2025/12/13 Re: [PR] [FLINK-38249] Add support for skipping specific Debezium operations in MySQL CDC source. [flink-cdc] via GitHub
• 2025/12/13 Re: [PR] [FLINK-38776][table] Fix incorrect auxiliary group field names [flink] via GitHub
• 2025/12/13 [jira] [Commented] (FLINK-38699) Order the WebUI's Completed Job List by end time order Yi Zhang (Jira)
• 2025/12/12 Re: [PR] [hotfix] Support passing arbitrary database options to JDBC Catalog [flink-connector-jdbc] via GitHub
• 2025/12/12 Re: [PR] [hotfix] Support passing arbitrary database options to JDBC Catalog [flink-connector-jdbc] via GitHub
• 2025/12/12 Re: [PR] [Feature][Java] Add MCP support in Java [flink-agents] via GitHub
• 2025/12/12 Re: [PR] [FLINK-38807][state] Add state SQL metadata based type inference [flink] via GitHub
• 2025/12/12 [jira] [Updated] (FLINK-38807) Add state SQL metadata based type inference ASF GitHub Bot (Jira)
• 2025/12/12 [PR] [FLINK-38807][state] Add state SQL metadata based type inference [flink] via GitHub
• 2025/12/12 Re: [PR] Kafka 4.x Queue Semantics support [flink-connector-kafka] via GitHub
• 2025/12/12 Re: [PR] [FLINK-38733] Add new SplitterEnumerator on JdbcSource [flink-connector-jdbc] via GitHub
• 2025/12/12 [jira] [Updated] (FLINK-38807) Add state SQL metadata based type inference Gabor Somogyi (Jira)
• 2025/12/12 Re: [PR] [FLINK-38733] Add new SplitterEnumerator on JdbcSource [flink-connector-jdbc] via GitHub
• 2025/12/12 [jira] [Created] (FLINK-38807) Add state SQL metadata type inference Gabor Somogyi (Jira)
• 2025/12/12 [jira] [Assigned] (FLINK-38807) Add state SQL metadata type inference Gabor Somogyi (Jira)
• 2025/12/12 Re: [PR] [FLINK-37627][BugFix][Connectors/Kinesis] Restarting from a checkpoint/savepoint which coincides with shard split causes data loss [flink-connector-aws] via GitHub
• 2025/12/12 [PR] [FLINK-37627][BugFix][Connectors/Kinesis] Restarting from a checkpoint/savepoint which coincides with shard split causes data loss [flink-connector-aws] via GitHub
• 2025/12/12 Re: [PR] [Feature][Java] Add MCP support in Java [flink-agents] via GitHub
• 2025/12/12 Re: [PR] [BP-2.1][FLINK-38486] Harden shutdown of system UDFs [flink] via GitHub
• 2025/12/12 Re: [PR] [BP-2.0][FLINK-38486] Harden shutdown of system UDFs [flink] via GitHub
• 2025/12/12 Re: [PR] [FLINK-38797][python] Fixed PyFlink issue CsvSchemaBuilder.set_null_value missing return self [flink] via GitHub
• 2025/12/12 Re: [PR] [FLINK-38802][table] DDL with duplicated keys in table options should fail while validation [flink] via GitHub
• 2025/12/12 Re: [PR] [FLINK-38802][table] DDL with duplicated keys in table options should fail while validation [flink] via GitHub
• 2025/12/12 Re: [PR] [hotfix] Support passing arbitrary database options to JDBC Catalog [flink-connector-jdbc] via GitHub
• 2025/12/12 [jira] [Assigned] (FLINK-37627) Restarting from a checkpoint/savepoint which coincides with shard split causes data loss Ferenc Csaky (Jira)
• 2025/12/12 [jira] [Updated] (FLINK-37627) Restarting from a checkpoint/savepoint which coincides with shard split causes data loss Ferenc Csaky (Jira)
• 2025/12/12 [jira] [Updated] (FLINK-37627) Restarting from a checkpoint/savepoint which coincides with shard split causes data loss Ferenc Csaky (Jira)
• 2025/12/12 Re: [PR] [FLINK-37627][BugFix][Connectors/Kinesis] Restarting from a checkpoint/savepoint which coincides with shard split causes data loss [flink-connector-aws] via GitHub

• Earlier messages
• Later messages