issues  

Messages by Date

• 2026/09/29 [jira] [Updated] (FLINK-40839) INSERT with a column list fails when an omitted column is of type VARIANT Ramin Gharib (Jira)
• 2026/09/29 [jira] [Commented] (FLINK-23598) DataOutputSerializer.writeBytes updates position twice Zhe Wang (Jira)
• 2026/09/29 Re: [PR] [FLINK-40743][jdbc] Fix the Table sink's empty lineage dataset name [flink-connector-jdbc] via GitHub
• 2026/09/29 [PR] [runtime][java] Surface Kafka action-state send failures [flink-agents] via GitHub
• 2026/09/29 Re: [PR] [runtime] Replay a durable call that returned null instead of throwing [flink-agents] via GitHub
• 2026/09/29 Re: [I] [Bug][runtime] Kafka action-state writes ignore asynchronous producer failures [flink-agents] via GitHub
• 2026/09/29 Re: [PR] [api][java][python] Reject non-positive max_results in ContextRetrievalRequestEvent [flink-agents] via GitHub
• 2026/09/29 Re: [I] [Bug][runtime] Replaying a durable call that returned null throws NullPointerException [flink-agents] via GitHub
• 2026/09/29 [jira] [Created] (FLINK-40840) INSERT with a column list fails when an omitted column is of type BITMAP, RAW or STRUCTURED Ramin Gharib (Jira)
• 2026/09/29 [jira] [Updated] (FLINK-40839) INSERT with a column list fails when an omitted column is of type VARIANT or BITMAP Ramin Gharib (Jira)
• 2026/09/29 [jira] [Updated] (FLINK-40839) INSERT with a column list fails when an omitted column is of type VARIANT or BITMAP Ramin Gharib (Jira)
• 2026/09/29 Re: [PR] [runtime] Replay a durable call that returned null instead of throwing [flink-agents] via GitHub
• 2026/09/29 Re: [PR] [runtime] Replay a durable call that returned null instead of throwing [flink-agents] via GitHub
• 2026/09/28 Re: [PR] [BP-2.3][FLINK-40568][tests] Fix flaky ProcessTableFunctionSemanticTests by using materialized data assertion [flink] via GitHub
• 2026/09/28 [PR] Add Flink CDC 3.7.0 release blog [flink-web] via GitHub
• 2026/09/28 Re: [PR] [FLINK-29549]- Flink Glue Catalog integration [flink-connector-aws] via GitHub
• 2026/09/28 Re: [PR] [FLINK-36456] feat: Add support to pass Datadog API Key as environment variable [flink] via GitHub
• 2026/09/28 [jira] [Commented] (FLINK-40568) ProcessTableFunctionSemanticTests[process-updating-multi-input] is flaky on master Martijn Visser (Jira)
• 2026/09/28 Re: [PR] [FLINK-29549]- Flink Glue Catalog integration [flink-connector-aws] via GitHub
• 2026/09/28 Re: [PR] [integration][java][python] Send multimodal user messages through OpenAI Chat Completions [flink-agents] via GitHub
• 2026/09/28 Re: [PR] [integration][java][python] Send multimodal user messages through OpenAI Chat Completions [flink-agents] via GitHub
• 2026/09/28 [jira] [Commented] (FLINK-35633) Early verification and clearer error message of pipeline YAML definition Xiqian Yu (Jira)
• 2026/09/28 Re: [PR] [integration][java][python] Send multimodal user messages through OpenAI Chat Completions [flink-agents] via GitHub
• 2026/09/28 [jira] [Resolved] (FLINK-38232) [docs] updates the connector documentation to reflect the new features in Flink CDC 3.5.0 Xiqian Yu (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-39342) [Iceberg] Support hadoop.conf.* prefix to pass Hadoop configuration properties Xiqian Yu (Jira)
• 2026/09/28 Re: [PR] [FLINK-40830][table] Reuse java's getBytes in StringUtf8Bytes [flink] via GitHub
• 2026/09/28 [jira] [Resolved] (FLINK-40151) Support missing YAML Transform predicates and nullable BOOLEAN logical evaluation Xiqian Yu (Jira)
• 2026/09/28 [jira] [Updated] (FLINK-40568) ProcessTableFunctionSemanticTests[process-updating-multi-input] is flaky on master Martijn Visser (Jira)
• 2026/09/28 Re: [PR] [FLINK-39382][docs] Clarify auto.offset.reset support in Kafka SQL connector [flink-connector-kafka] via GitHub
• 2026/09/28 [jira] [Commented] (FLINK-38840) Postgres YAML connector supports emitting complete Table ID Xiqian Yu (Jira)
• 2026/09/28 Re: [PR] [runtime][java] Complete batch workflows before key switches [flink-agents] via GitHub
• 2026/09/28 [jira] [Resolved] (FLINK-39335) Upgrade `flink-connector-starrocks` to no longer require compatibility with Flink 1.19. Xiqian Yu (Jira)
• 2026/09/28 [jira] [Resolved] (FLINK-40159) Support Hive metastore sync for Hudi pipeline sink Xiqian Yu (Jira)
• 2026/09/28 Re: [PR] [plan][java][python] Unify function schemas and argument validation [flink-agents] via GitHub
• 2026/09/28 Re: [I] [Tech Debt][API][Tool] Unify function-schema derivation and argument validation [flink-agents] via GitHub
• 2026/09/28 [jira] [Updated] (FLINK-40349) Add Fluss sink schema compatibility option to avoid silent data loss Xiqian Yu (Jira)
• 2026/09/28 [jira] [Resolved] (FLINK-40740) Fluss source can assign the same splits more than once during periodic discovery Hongshun Wang (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-38737) Introducing fallback keys can cause validateFactoryOptions to fail Xiqian Yu (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-34677) Refactor the structure of documentation for Flink CDC Xiqian Yu (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-34742) Translate "FAQ" Page for Flink CDC Chinese Documentation Xiqian Yu (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-35077) Add package license check for Flink CDC modules. Xiqian Yu (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-35281) FlinkEnvironmentUtils#addJar add each jar only once Xiqian Yu (Jira)
• 2026/09/28 [jira] [Resolved] (FLINK-36763) Support schema inference and evolution with single-table-mutliple-partition sources Xiqian Yu (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-36763) Support schema inference and evolution with single-table-mutliple-partition sources Xiqian Yu (Jira)
• 2026/09/28 [jira] [Resolved] (FLINK-37587) Fail to add a new column that has the same column name with source table using transform Xiqian Yu (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-36978) Fix the bug where the command-line option `from-savepoint` is invalid in K8s deployment mode. Xiqian Yu (Jira)
• 2026/09/28 [jira] [Updated] (FLINK-40740) Fluss source can assign the same splits more than once during periodic discovery Hongshun Wang (Jira)
• 2026/09/28 [jira] [Resolved] (FLINK-36978) Fix the bug where the command-line option `from-savepoint` is invalid in K8s deployment mode. Xiqian Yu (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-38156) Pipeline E2E tests are currently bound to fail. Xiqian Yu (Jira)
• 2026/09/28 [jira] [Resolved] (FLINK-39363) [Flaky Tests] PaimonSinkITCase.testDuplicateCommitAfterRestore Xiqian Yu (Jira)
• 2026/09/28 [jira] [Updated] (FLINK-39048) [iceberg] Bump iceberg-flink-runtime from 1.19 to 1.20 Xiqian Yu (Jira)
• 2026/09/28 [jira] [Updated] (FLINK-40740) Fluss source can assign the same splits more than once during periodic discovery Hongshun Wang (Jira)
• 2026/09/28 [jira] [Resolved] (FLINK-39144) fix IOManager not close Xiqian Yu (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-37587) Fail to add a new column that has the same column name with source table using transform Xiqian Yu (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-38188) PostgreSQL connector database name validation logic is inverted in getValidateDatabaseName method Xiqian Yu (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-34735) "Developer Guide - Understanding Flink CDC API" Page for Flink CDC Chinese Documentation Xiqian Yu (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-38452) MongoDB CDC connector could not read from collections named with dots Xiqian Yu (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-38157) Postgres cdc pipeline supported @experimental options like mysql pipeline Xiqian Yu (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-38232) [docs] updates the connector documentation to reflect the new features in Flink CDC 3.5.0 Xiqian Yu (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-40151) Support missing YAML Transform predicates and nullable BOOLEAN logical evaluation Xiqian Yu (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-38723) Provide Flink Configuration in the Context when Building DataSink/DataSource Xiqian Yu (Jira)
• 2026/09/28 [jira] [Resolved] (FLINK-38723) Provide Flink Configuration in the Context when Building DataSink/DataSource Xiqian Yu (Jira)
• 2026/09/28 [jira] [Resolved] (FLINK-38806) Pipeline post-transform converters ineffective without a projection rule Xiqian Yu (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-38806) Pipeline post-transform converters ineffective without a projection rule Xiqian Yu (Jira)
• 2026/09/28 [jira] [Resolved] (FLINK-38737) Introducing fallback keys can cause validateFactoryOptions to fail Xiqian Yu (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-39300) [flink-cdc] Reuse ObjectMapper as static constant to avoid repeated instantiation Xiqian Yu (Jira)
• 2026/09/28 [jira] [Resolved] (FLINK-39329) [MySQL-CDC] Improve error message for tables without primary key in incremental snapshot Xiqian Yu (Jira)
• 2026/09/28 Re: [PR] [FLINK-40740][pipeline-connector/fluss] Prevent duplicate split initialization during discovery [flink-cdc] via GitHub
• 2026/09/28 [jira] [Resolved] (FLINK-38840) Postgres YAML connector supports emitting complete Table ID Xiqian Yu (Jira)
• 2026/09/28 [jira] [Resolved] (FLINK-37676) Add a cache for TableId in Selector to improve performance Xiqian Yu (Jira)
• 2026/09/28 [jira] [Resolved] (FLINK-38838) Update version of googleJavaFormat to AOSP 1.24.0 Xiqian Yu (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-38808) Support partition transforms in Iceberg sink Xiqian Yu (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-39048) [iceberg] Bump iceberg-flink-runtime from 1.19 to 1.20 Xiqian Yu (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-39063) FIx some spelling mistakes in fluss connector Xiqian Yu (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-37586) YAML pipeline supports passing extra options to UDFs Xiqian Yu (Jira)
• 2026/09/28 [jira] [Resolved] (FLINK-38647) NullPointerException in Postgres CDC pipeline when update data in table Xiqian Yu (Jira)
• 2026/09/28 [jira] [Resolved] (FLINK-39417) YAML Pipeline could not [de]serialize GenericRecordData Xiqian Yu (Jira)
• 2026/09/28 [jira] [Resolved] (FLINK-37586) YAML pipeline supports passing extra options to UDFs Xiqian Yu (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-39144) fix IOManager not close Xiqian Yu (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-39171) Oracle pipeline transform fails with quoted uppercase projection columns Xiqian Yu (Jira)
• 2026/09/28 [jira] [Resolved] (FLINK-39171) Oracle pipeline transform fails with quoted uppercase projection columns Xiqian Yu (Jira)
• 2026/09/28 [jira] [Assigned] (FLINK-39300) [flink-cdc] Reuse ObjectMapper as static constant to avoid repeated instantiation Xiqian Yu (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-39335) Upgrade `flink-connector-starrocks` to no longer require compatibility with Flink 1.19. Xiqian Yu (Jira)
• 2026/09/28 [jira] [Updated] (FLINK-39718) Paimon pipeline sink fails with distributed source when target table does not exist Xiqian Yu (Jira)
• 2026/09/28 Re: [I] [Bug] Tongyi connection sends tool results without a tool_call_id [flink-agents] via GitHub
• 2026/09/28 [jira] [Resolved] (FLINK-39337) Clean up the compatibility code for Flink 1.19 in the `e2e-tests` module. Xiqian Yu (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-39337) Clean up the compatibility code for Flink 1.19 in the `e2e-tests` module. Xiqian Yu (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-39346) Improve the error message when the AddColumnEvent fails Xiqian Yu (Jira)
• 2026/09/28 [jira] [Resolved] (FLINK-39336) Clean up code in the `flink-cdc-pipeline-connector-kafka` module that is compatible with older versions of Flink. Xiqian Yu (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-39336) Clean up code in the `flink-cdc-pipeline-connector-kafka` module that is compatible with older versions of Flink. Xiqian Yu (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-39372) Potential MySQL Binlog offset comparison failure after mysql-bin.999999 Xiqian Yu (Jira)
• 2026/09/28 [jira] [Resolved] (FLINK-38061) Caused by: java.util.ConcurrentModificationException When the MySql Chunk Split stage triggers a checkpoint Xiqian Yu (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-38742) Postgres CDC pipeline fails when there is column of type TIMESTAMPTZ (timestamp with timezone) Xiqian Yu (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-39363) [Flaky Tests] PaimonSinkITCase.testDuplicateCommitAfterRestore Xiqian Yu (Jira)
• 2026/09/28 [jira] [Assigned] (FLINK-38061) Caused by: java.util.ConcurrentModificationException When the MySql Chunk Split stage triggers a checkpoint Xiqian Yu (Jira)
• 2026/09/28 [jira] [Resolved] (FLINK-38742) Postgres CDC pipeline fails when there is column of type TIMESTAMPTZ (timestamp with timezone) Xiqian Yu (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-38061) Caused by: java.util.ConcurrentModificationException When the MySql Chunk Split stage triggers a checkpoint Xiqian Yu (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-39684) YAML PaimonWriter throws NullPointerException when handling REPLACE event Xiqian Yu (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-39573) Build documentation CI workflow fails with startup_failure due to burnett01/rsync-deployments action not allowed Xiqian Yu (Jira)
• 2026/09/28 [jira] [Resolved] (FLINK-39573) Build documentation CI workflow fails with startup_failure due to burnett01/rsync-deployments action not allowed Xiqian Yu (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-40223) Support additional Flink SQL string functions in YAML Transform Xiqian Yu (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-39696) Distributed SchemaOperator emits FlushEvent with schema operator subtaskId instead of upstream sourcePartition Xiqian Yu (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-39682) Unable to invoke TO_DATE with TIMESTAMP types Xiqian Yu (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-39698) Fix incorrect content in SQLServer CDC connector documentation Xiqian Yu (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-40091) upgrade paimon to 1.4.2 Xiqian Yu (Jira)
• 2026/09/28 [jira] [Updated] (FLINK-40538) [Postgres] Connector never starts streaming on a database with no publication traffic Xiqian Yu (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-40159) Support Hive metastore sync for Hudi pipeline sink Xiqian Yu (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-40007) Fix Postgres CDC snapshot fetch size conf does not take effect Xiqian Yu (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-40202) HybridSplitAssigner may initialize enumerator metrics concurrently with snapshot split assignment Xiqian Yu (Jira)
• 2026/09/28 [jira] [Updated] (FLINK-39833) Special characters in column comment and default value are not escaped when building DDL Xiqian Yu (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-39568) Decouple YAML built-in AI Function and model providers Xiqian Yu (Jira)
• 2026/09/28 [jira] [Updated] (FLINK-40533) Upgrade Flink CDC dependency to Flink 2.3 Xiqian Yu (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-40627) Partially fetched user artifacts are reused on subsequent starts Robert Metzger (Jira)
• 2026/09/28 [jira] [Assigned] (FLINK-40627) Partially fetched user artifacts are reused on subsequent starts Robert Metzger (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-40411) Introduce an OpenAI-compatible model client for Flink CDC Pipeline Xiqian Yu (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-40512) PostgreSQL yaml source is busy on inferring schema change event Xiqian Yu (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-40453) [postgres] Avoid eagerly loading all table schemas when initializing PostgresPipelineRecordEmitter Xiqian Yu (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-40313) Support collection constructors and functions in YAML Transform Xiqian Yu (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-40416) Add built-in text AI functions to Pipeline transforms Xiqian Yu (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-40507) upgrade paimon to 2.0.0 Xiqian Yu (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-39416) Fix link address errors in documents Xiqian Yu (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-40572) Support dynamic model selection for AI functions Xiqian Yu (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-40656) Distributed schema coordinator can remain EVOLVING after checkpoint restore Xiqian Yu (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-40514) [Docs] Doris pipeline connector option table does not match implementation Xiqian Yu (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-40739) [Bug][pipeline-connector][maxcompute] Partition values extracted from wrong column index when partition columns are not contiguous at the end of schema Xiqian Yu (Jira)
• 2026/09/28 [jira] [Updated] (FLINK-39391) scan.snapshot.fetch.size is not propagated to Debezium properties in Oracle/SqlServer/DB2/Postgres connectors, causing severe snapshot performance degradation Xiqian Yu (Jira)
• 2026/09/28 [jira] [Updated] (FLINK-39749) [mysql-cdc] Introduce scan.incremental.snapshot.string-key.compare-mode to align Java and MySQL ordering for string chunk keys Xiqian Yu (Jira)
• 2026/09/28 [jira] [Updated] (FLINK-40087) MySqlDefaultValueConverter fails to parse charset-introducer default values wrapped in double quotes and/or containing padding spaces (e.g. `_UTF8MB4" 0 "`) Xiqian Yu (Jira)
• 2026/09/28 [jira] [Updated] (FLINK-39569) YAML pipeline supports HLS live-streaming video source Xiqian Yu (Jira)
• 2026/09/28 [jira] [Closed] (FLINK-39569) YAML pipeline supports HLS live-streaming video source Xiqian Yu (Jira)
• 2026/09/28 [jira] [Updated] (FLINK-39386) For Flink 2.x+, support limit the rate at the source Xiqian Yu (Jira)
• 2026/09/28 Re: [PR] [FLINK-24908][sql-client] Print the outermost exception that ends with the root cause [flink] via GitHub
• 2026/09/28 Re: [PR] [FLINK-24908][table-planner] Include the parser position in SqlParserException messages [flink] via GitHub
• 2026/09/28 [PR] [FLINK-24908][table-planner] Include the parser position in SqlParserException messages [flink] via GitHub
• 2026/09/28 [PR] [FLINK-24908][sql-client] Print the outermost exception that ends with the root cause [flink] via GitHub
• 2026/09/28 Re: [PR] [FLINK-40830][table] Reuse java's getBytes in StringUtf8Bytes [flink] via GitHub
• 2026/09/28 [jira] [Updated] (FLINK-36581) Allow passing Flink configuration by yaml job file or command line parameters Leonard Xu (Jira)
• 2026/09/28 [jira] [Updated] (FLINK-36581) Allow passing Flink configuration by yaml job file or command line parameters Leonard Xu (Jira)
• 2026/09/28 Re: [PR] [BP-2.3][FLINK-40504][runtime] Re-activate idle FLIP-27 outputs when they resume [flink] via GitHub
• 2026/09/28 Re: [PR] [BP-2.2][FLINK-40504][runtime] Re-activate idle FLIP-27 outputs when they resume [flink] via GitHub
• 2026/09/28 Re: [I] [Bug] Java Ollama connection drops assistant tool calls from the chat history [flink-agents] via GitHub
• 2026/09/28 Re: [PR] [integration][java] Forward assistant tool calls in the Ollama chat history [flink-agents] via GitHub
• 2026/09/28 [jira] [Comment Edited] (FLINK-40488) Comparison and ordering for UUID dylanhz (Jira)
• 2026/09/28 [PR] [plan][java][python] Unify function schemas and argument validation [flink-agents] via GitHub
• 2026/09/28 [jira] [Resolved] (FLINK-40512) PostgreSQL yaml source is busy on inferring schema change event Xiqian Yu (Jira)
• 2026/09/28 [jira] [Closed] (FLINK-39721) Flink CDC YAML framework should be compatibility with Flink 1.18. Xiqian Yu (Jira)
• 2026/09/28 [jira] [Resolved] (FLINK-40480) [doc] CDC Yaml supports fluss source. Xiqian Yu (Jira)
• 2026/09/28 [jira] [Resolved] (FLINK-40091) upgrade paimon to 1.4.2 Xiqian Yu (Jira)
• 2026/09/28 Re: [PR] [FLINK-25453] [core] Ignore files deleted concurrently in LocalFileSystem#listStatus [flink] via GitHub
• 2026/09/28 Re: [PR] [api][plan][runtime][python] Rebuild registered sub-agent setups from descriptors [flink-agents] via GitHub
• 2026/09/28 [PR] [BP-2.2][FLINK-40504][runtime] Re-activate idle FLIP-27 outputs when they resume [flink] via GitHub
• 2026/09/28 [PR] [build] Bump version to 3.8-SNAPSHOT [flink-cdc] via GitHub
• 2026/09/28 Re: [I] [Feature] Support registering ReActAgent as a general-purpose subagent [flink-agents] via GitHub
• 2026/09/28 Re: [PR] [FLINK-38592] Initial Native Flink S3 FileSystem [flink] via GitHub
• 2026/09/28 Re: [I] [Feature][runtime] Support parallel action execution on JDK < 21 [flink-agents] via GitHub
• 2026/09/28 Re: [PR] [api][runtime] Support parallel action execution on JDK < 21 [flink-agents] via GitHub
• 2026/09/28 Re: [I] [Bug][plan] sub-agent cannot be rebuilt on a remote task after plan serialization [flink-agents] via GitHub
• 2026/09/28 Re: [PR] [FLINK-36581][cli] Allow passing Flink configuration by yaml job file [flink-cdc] via GitHub
• 2026/09/28 Re: [PR] [FLINK-40739][maxcompute] Fix partition handling for sink writes [flink-cdc] via GitHub
• 2026/09/28 [PR] [BP-2.3][FLINK-40504][runtime] Re-activate idle FLIP-27 outputs when they resume [flink] via GitHub
• 2026/09/28 [jira] [Commented] (FLINK-40504) FLIP-27 source never re-emits WatermarkStatus.ACTIVE after idleness unless its watermark strictly advances yongfu.gao (Jira)
• 2026/09/28 [PR] [runtime][java] Preserve pending Fluss action state across checkpoints [flink-agents] via GitHub
• 2026/09/28 Re: [PR] [FLINK-40744][jdbc] Remove the dead InputFormat and OutputFormat classes [flink-connector-jdbc] via GitHub
• 2026/09/28 [I] [Bug][runtime] Fluss recovery can skip saved results for pending actions [flink-agents] via GitHub
• 2026/09/28 Re: [PR] [FLINK-40538][postgres] Skip WAL position search on idle publication … [flink-cdc] via GitHub
• 2026/09/28 [jira] [Updated] (FLINK-40839) INSERT with a column list fails when an omitted column is of type VARIANT or BITMAP Ramin Gharib (Jira)
• 2026/09/28 Re: [PR] [api][java][python] Reject non-positive max_results in ContextRetrievalRequestEvent [flink-agents] via GitHub
• 2026/09/28 Re: [PR] [FLINK-40108] Adding snapshot capability with split enumerator [flink-connector-jdbc] via GitHub
• 2026/09/28 Re: [PR] [BP-2.2][FLINK-40568][tests] Fix flaky ProcessTableFunctionSemanticTests by using materialized data assertion [flink] via GitHub
• 2026/09/28 Re: [PR] [FLINK-40676] Support Flink 2.0.x and Pulsar Client 4.0.9 [flink-connector-pulsar] via GitHub
• 2026/09/28 Re: [PR] [FLINK-39697] Bump Flink version to 2.2.1 [flink-connector-pulsar] via GitHub
• 2026/09/28 Re: [PR] [FLINK-40839][table] Support VARIANT and BITMAP columns omitted from an INSERT column list [flink] via GitHub
• 2026/09/28 [PR] [FLINK-40839][table] Support VARIANT and BITMAP columns omitted from an INSERT column list [flink] via GitHub
• 2026/09/28 [jira] [Updated] (FLINK-40839) INSERT with a column list fails when an omitted column is of type VARIANT or BITMAP ASF GitHub Bot (Jira)
• 2026/09/28 [jira] [Created] (FLINK-40839) INSERT with a column list fails when an omitted column is of type VARIANT or BITMAP Ramin Gharib (Jira)
• 2026/09/28 Re: [PR] [FLINK-29549]- Flink Glue Catalog integration [flink-connector-aws] via GitHub
• 2026/09/28 [jira] [Commented] (FLINK-40504) FLIP-27 source never re-emits WatermarkStatus.ACTIVE after idleness unless its watermark strictly advances Roman Khachatryan (Jira)
• 2026/09/28 Re: [PR] [FLINK-40504][runtime] Re-activate idle FLIP-27 outputs when they resume [flink] via GitHub
• 2026/09/28 Re: [PR] [FLINK-40504][runtime] Re-activate idle FLIP-27 outputs when they resume [flink] via GitHub
• 2026/09/28 Re: [PR] [FLINK-40504][runtime] Re-activate idle FLIP-27 outputs when they resume [flink] via GitHub
• 2026/09/28 Re: [PR] [FLINK-32451][tests] Rewrite the Confluent Schema Registry e2e test without the Kafka connector [flink] via GitHub
• 2026/09/28 [jira] [Resolved] (FLINK-38534) Fix flaky LocalRecoveryTest by waiting for tasks to reach RUNNING state Martijn Visser (Jira)
• 2026/09/28 Re: [PR] [BP-2.3][FLINK-38534][runtime/tests] Fix LocalRecoveryTest racing the async task deployment [flink] via GitHub
• 2026/09/28 Re: [PR] [runtime][java] Replay pending Kafka action state on recovery [flink-agents] via GitHub
• 2026/09/28 [jira] [Updated] (FLINK-32451) Refactor Confluent Schema Registry E2E Tests to remove Kafka connector dependency ASF GitHub Bot (Jira)
• 2026/09/28 [jira] [Updated] (FLINK-40838) Add a DataStream end-to-end test for the Confluent Schema Registry format ASF GitHub Bot (Jira)
• 2026/09/28 [PR] [FLINK-40838][tests] Add a DataStream end-to-end test for the Confluent Schema Registry format [flink-connector-kafka] via GitHub
• 2026/09/28 [PR] [FLINK-32451][tests] Rewrite the Confluent Schema Registry e2e test without the Kafka connector [flink] via GitHub
• 2026/09/28 [jira] [Updated] (FLINK-40838) Add a DataStream end-to-end test for the Confluent Schema Registry format Martijn Visser (Jira)
• 2026/09/28 [jira] [Assigned] (FLINK-32451) Refactor Confluent Schema Registry E2E Tests to remove Kafka connector dependency Martijn Visser (Jira)
• 2026/09/28 [jira] [Updated] (FLINK-32451) Refactor Confluent Schema Registry E2E Tests to remove Kafka connector dependency Martijn Visser (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-36454) FlinkContainer always overwrites default config Martijn Visser (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-39674) flink-avro-confluent-registry uses an obsolete schema registry client Martijn Visser (Jira)
• 2026/09/28 [jira] [Closed] (FLINK-36268) Disable Avro Confluent Schema Registry nightly end-to-end test for 2.0 breaking change Martijn Visser (Jira)
• 2026/09/28 [jira] [Created] (FLINK-40838) Add a DataStream end-to-end test for the Confluent Schema Registry format Martijn Visser (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-36413) Reenable the test case that related to Source/Sink APi deprecated. Martijn Visser (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-26109) Avro Confluent Schema Registry nightly end-to-end test failed on azure Martijn Visser (Jira)
• 2026/09/28 [jira] [Closed] (FLINK-26109) Avro Confluent Schema Registry nightly end-to-end test failed on azure Martijn Visser (Jira)
• 2026/09/28 [jira] [Updated] (FLINK-36413) Reenable the test case that related to Source/Sink APi deprecated. Martijn Visser (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-36268) Disable Avro Confluent Schema Registry nightly end-to-end test for 2.0 breaking change Martijn Visser (Jira)

• Earlier messages
• Later messages