issues  

Messages by Date

• 2026/10/22 Re: [PR] [FLINK-36299][runtime] Start scheduling and offer the slot in one main-thread task in AdaptiveSchedulerTest.testStatusMetrics [flink] via GitHub
• 2026/10/22 [jira] [Resolved] (FLINK-40617) Connectors/Kafka: Prune and bump dependency versions in the root pom Martijn Visser (Jira)
• 2026/10/22 Re: [PR] [FLINK-40617][build] Prune and bump dependency versions in the root pom [flink-connector-kafka] via GitHub
• 2026/10/22 Re: [PR] [FLINK-34625][python] Fix state TTL read cache disabling [flink] via GitHub
• 2026/10/22 Re: [D] Flink Agents Release Process [flink-agents] via GitHub
• 2026/10/22 [PR] [docs] [flink-cdc] via GitHub
• 2026/10/22 Re: [PR] [BP-1.20][FLINK-38574][checkpoint] Avoid reusing re-uploaded sst files when checkpoint notification is delayed [flink] via GitHub
• 2026/10/22 [PR] [FLINK-34625][python] Fix state TTL read cache disabling [flink] via GitHub
• 2026/10/22 [jira] [Updated] (FLINK-34625) TTL doesn't seem to work in pyflink ASF GitHub Bot (Jira)
• 2026/10/22 [jira] [Created] (FLINK-41099) Streaming RANK() / DENSE_RANK() OVER a non-time ORDER BY ignore ties (return the row count instead of the rank) Yaoxuan Wu (Jira)
• 2026/10/22 [jira] [Updated] (FLINK-41099) Streaming RANK() / DENSE_RANK() OVER a non-time ORDER BY ignore ties (return the row count instead of the rank) Yaoxuan Wu (Jira)
• 2026/10/22 [jira] [Updated] (FLINK-41099) Streaming RANK() / DENSE_RANK() OVER a non-time ORDER BY ignore ties (return the row count instead of the rank) Yaoxuan Wu (Jira)
• 2026/10/22 [jira] [Created] (FLINK-41098) Streaming mode: IN / NOT IN in the SELECT list drops all rows when the subquery result is empty Yaoxuan Wu (Jira)
• 2026/10/22 [jira] [Created] (FLINK-41097) AVG returns NULL for a group with a NULL value once adaptive local hash aggregation switches to bypass mode Yaoxuan Wu (Jira)
• 2026/10/22 [jira] [Updated] (FLINK-40710) Dynamic Kafka Source assigns duplicate partition owners after local failover Bowen Li (Jira)
• 2026/10/22 [jira] [Commented] (FLINK-40710) Dynamic Kafka Source assigns duplicate partition owners after local failover Bowen Li (Jira)
• 2026/10/22 [jira] [Resolved] (FLINK-40710) Dynamic Kafka Source assigns duplicate partition owners after local failover Bowen Li (Jira)
• 2026/10/22 Re: [I] [Bug][runtime][java][python] Model-driven subagent await failures leave pending handles and fail the action [flink-agents] via GitHub
• 2026/10/22 Re: [PR] [FLINK-41061] Reduce sleep frequency of adaptive partition selection benchmark [flink-benchmarks] via GitHub
• 2026/10/22 Re: [PR] [FLINK-41061] Reduce sleep frequency of adaptive partition selection benchmark [flink-benchmarks] via GitHub
• 2026/10/22 Re: [PR] [FLINK-41028] Support data lake table properties in the Fluss pipeline sink [flink-cdc] via GitHub
• 2026/10/22 [jira] [Updated] (FLINK-26050) Too many small sst files in rocksdb state backend when using time window created in ascending order Feifan Wang (Jira)
• 2026/10/22 Re: [D] Flink Agents Release Process [flink-agents] via GitHub
• 2026/10/22 Re: [PR] [BP-3.6][FLINK-39573][docs] Fix Build documentation CI for release-3.6 [flink-cdc] via GitHub
• 2026/10/22 [PR] [hotfix][docs] Centralize stable release versions in setup examples [flink-agents] via GitHub
• 2026/10/22 Re: [PR] [FLINK-40135][python] Prevent Beam state access after runner shutdown [flink] via GitHub
• 2026/10/22 Re: [PR] [FLINK-40135][python] Prevent Beam state access after runner shutdown [flink] via GitHub
• 2026/10/22 Re: [PR] [BP-3.6][FLINK-39573][docs] Fix Build documentation CI for release-3.6 [flink-cdc] via GitHub
• 2026/10/22 Re: [D] Flink Agents Release Process [flink-agents] via GitHub
• 2026/10/22 [PR] [BP-3.6][FLINK-39573][docs] Fix Build documentation CI for release-3.6 [flink-cdc] via GitHub
• 2026/10/22 Re: [D] Flink Agents Release Process [flink-agents] via GitHub
• 2026/10/22 Re: [D] Flink Agents Release Process [flink-agents] via GitHub
• 2026/10/22 Re: [PR] [FLINK-41061] Reduce sleep frequency of adaptive partition selection benchmark [flink-benchmarks] via GitHub
• 2026/10/22 Re: [D] Flink Agents Release Process [flink-agents] via GitHub
• 2026/10/22 [jira] [Updated] (FLINK-40216) [cdc-base] Meta groups of finished snapshot splits become inconsistent after restore due to lexicographic re-sorting of assigned splits Leonard Xu (Jira)
• 2026/10/22 [jira] [Resolved] (FLINK-40216) [cdc-base] Meta groups of finished snapshot splits become inconsistent after restore due to lexicographic re-sorting of assigned splits Leonard Xu (Jira)
• 2026/10/22 [jira] [Assigned] (FLINK-40216) [cdc-base] Meta groups of finished snapshot splits become inconsistent after restore due to lexicographic re-sorting of assigned splits Leonard Xu (Jira)
• 2026/10/22 Re: [D] Flink Agents Release Process [flink-agents] via GitHub
• 2026/10/22 Re: [D] Flink Agents Release Process [flink-agents] via GitHub
• 2026/10/22 Re: [PR] [FLINK-41054][metrics] Add exclude filter for the metric query service [flink] via GitHub
• 2026/10/22 Re: [I] [Bug][runtime][java][python] Model-driven subagent await failures leave pending handles and fail the action [flink-agents] via GitHub
• 2026/10/22 [PR] [runtime][java][python] Release subagent handles after await failures [flink-agents] via GitHub
• 2026/10/22 Re: [PR] [runtime][java] Preserve an existing KeyedStream's business key when no key selector is given [flink-agents] via GitHub
• 2026/10/22 Re: [PR] [FLINK-40710][Connectors/Kafka] Preserve Dynamic Kafka partition ownership during reader recovery [flink-connector-kafka] via GitHub
• 2026/10/22 Re: [I] [Bug][runtime] Continuation execution ignores max-in-flight-input-records on JDK 21 [flink-agents] via GitHub
• 2026/10/22 Re: [I] [Feature][chat-models] Support multimodal tool results in model provider adapters [flink-agents] via GitHub
• 2026/10/22 Re: [PR] [runtime] Bound continuation inputs and prioritize queued async work by record start order [flink-agents] via GitHub
• 2026/10/22 Re: [PR] [FLINK-40216][cdc-base] Preserve assignment order of splits across restore to keep meta groups consistent [flink-cdc] via GitHub
• 2026/10/22 Re: [PR] [runtime][java] Preserve an existing KeyedStream's business key when no key selector is given [flink-agents] via GitHub
• 2026/10/22 Re: [PR] [FLINK-41082] Polish Flink CDC docs and fix format issues [flink-cdc] via GitHub
• 2026/10/22 Re: [PR] [FLINK-41056][table] Keep non-compact decimals with unscaled value fitting in a long as long to avoid BigDecimal on read, add, subtract, cast and deserialize [flink] via GitHub
• 2026/10/22 Re: [PR] [FLINK-41094][state/forst] Fail async map access on iterator errors and close iterators by owner only [flink] via GitHub
• 2026/10/22 Re: [PR] [hotfix] [docs] Fix broken flink-training links in hands-on section [flink] via GitHub
• 2026/10/22 [PR] [FLINK-41095][runtime/state] Honor null removals in MapStateAdaptor [flink] via GitHub
• 2026/10/22 Re: [PR] [FLINK-41095][runtime/state] Honor null removals in MapStateAdaptor [flink] via GitHub
• 2026/10/22 Re: [PR] [FLINK-41094][state/forst] Fail async map access on iterator errors and close iterators by owner only [flink] via GitHub
• 2026/10/22 Re: [PR] [FLINK-41093][state] Honor State V2 TTL in AsyncKeyedStateBackendAdaptor [flink] via GitHub
• 2026/10/22 Re: [PR] [FLINK-41094][state/forst] Fail async map access on iterator errors and close iterators by owner only [flink] via GitHub
• 2026/10/22 [jira] [Updated] (FLINK-41094) ForSt async MapState operations ignore RocksIterator#status() on invalid iterators and close batch iterators across threads ASF GitHub Bot (Jira)
• 2026/10/22 [jira] [Updated] (FLINK-41093) AsyncKeyedStateBackendAdaptor ignores the TTL config of State V2 descriptors ASF GitHub Bot (Jira)
• 2026/10/22 [jira] [Updated] (FLINK-41095) MapStateAdaptor does not remove keys mapped to null in asyncPut and asyncPutAll ASF GitHub Bot (Jira)
• 2026/10/22 [PR] [FLINK-41093][state] Honor State V2 TTL in AsyncKeyedStateBackendAdaptor [flink] via GitHub
• 2026/10/22 [PR] [FLINK-41094][state/forst] Fail async map access on iterator errors and close iterators by owner only [flink] via GitHub
• 2026/10/22 [jira] [Commented] (FLINK-41086) JSON_LENGTH and JSON_TYPE fail the job when a JSON path function throws Yahya Kisana (Jira)
• 2026/10/22 [jira] [Created] (FLINK-41096) Wrong result when a Table with a non-equi correlated scalar subquery is used twice in one query Yaoxuan Wu (Jira)
• 2026/10/22 Re: [PR] [FLINK-40710][Connectors/Kafka] Preserve Dynamic Kafka partition ownership during reader recovery [flink-connector-kafka] via GitHub
• 2026/10/22 Re: [PR] [FLINK-31006][Connectors/Kafka] Signal no more splits after a restored bounded enumerator finds no partition changes [flink-connector-kafka] via GitHub
• 2026/10/22 [jira] [Created] (FLINK-41095) MapStateAdaptor does not remove keys mapped to null in asyncPut and asyncPutAll Aaron He (Jira)
• 2026/10/22 [PR] [FLINK-41092][state/rocksdb] Restore KEY_VALUE_V2 keyed-state metadata in RocksDB [flink] via GitHub
• 2026/10/22 [jira] [Created] (FLINK-41094) ForSt async MapState operations ignore RocksIterator#status() on invalid iterators and close batch iterators across threads Aaron He (Jira)
• 2026/10/22 [jira] [Created] (FLINK-41093) AsyncKeyedStateBackendAdaptor ignores the TTL config of State V2 descriptors Aaron He (Jira)
• 2026/10/22 [jira] [Created] (FLINK-41091) Honor null-entry removal and reject null maps in ForSt asyncPutAll Aaron He (Jira)
• 2026/10/22 Re: [PR] [FLINK-41092][state/rocksdb] Restore KEY_VALUE_V2 keyed-state metadata in RocksDB [flink] via GitHub
• 2026/10/22 [jira] [Updated] (FLINK-41092) RocksDB restore fails with ClassCastException when restoring KEY_VALUE_V2 state metadata from async ForSt ASF GitHub Bot (Jira)
• 2026/10/22 [jira] [Created] (FLINK-41092) RocksDB restore fails with ClassCastException when restoring KEY_VALUE_V2 state metadata from async ForSt Aaron He (Jira)
• 2026/10/22 Re: [PR] [FLINK-41091][runtime/state] Honor null removals in MapStateAdaptor [flink] via GitHub
• 2026/10/22 [jira] [Updated] (FLINK-41091) Honor null-entry removal and reject null maps in ForSt asyncPutAll ASF GitHub Bot (Jira)
• 2026/10/22 Re: [PR] [FLINK-41091][runtime/state] Honor null removals in MapStateAdaptor [flink] via GitHub
• 2026/10/22 Re: [PR] [FLINK-36902][core] Keep process exit working on JDK 24+ where the Security Manager is disabled [flink] via GitHub
• 2026/10/22 Re: [PR] [FLINK-36902][core] Keep process exit working on JDK 24+ where the Security Manager is disabled [flink] via GitHub
• 2026/10/22 [PR] [FLINK-41091][runtime/state] Honor null removals in MapStateAdaptor [flink] via GitHub
• 2026/10/22 [jira] [Updated] (FLINK-41090) Operator coordinators of uninitialized vertices are never closed Utkarsh Vashishtha (Jira)
• 2026/10/22 Re: [PR] [FLINK-41056][table] Keep non-compact decimals with unscaled value fitting in a long as long to avoid BigDecimal on read, add, subtract, cast and deserialize [flink] via GitHub
• 2026/10/22 Re: [PR] [FLINK-41009][connector/pulsar] Use a single transaction per checkpoint [flink-connector-pulsar] via GitHub
• 2026/10/22 [jira] [Created] (FLINK-41090) Operator coordinators of uninitialized vertices are never closed Utkarsh Vashishtha (Jira)
• 2026/10/22 Re: [PR] [FLINK-40842][table] Handle upsert inputs in the streaming semi/anti join [flink] via GitHub
• 2026/10/22 Re: [PR] [FLINK-41089][ci] Make cleanup of docker image parallel [flink] via GitHub
• 2026/10/22 Re: [PR] [FLINK-41049][ci] Make pre-downloaded Maven usable by the only-script Maven wrapper [flink] via GitHub
• 2026/10/22 [jira] [Updated] (FLINK-40842) Streaming semi/anti join over-counts matches for right-side updates without UPDATE_BEFORE ASF GitHub Bot (Jira)
• 2026/10/22 [PR] [FLINK-40842][table] Handle upsert inputs in the streaming semi/anti join [flink] via GitHub
• 2026/10/22 [jira] [Updated] (FLINK-41089) Make cleanup of docker image parallel ASF GitHub Bot (Jira)
• 2026/10/22 [PR] [FLINK-41089][ci] Make cleanup of docker image parallel [flink] via GitHub
• 2026/10/22 [jira] [Created] (FLINK-41089) Make cleanup of docker image parallel Sergey Nuyanzin (Jira)
• 2026/10/22 [PR] [FLINK-41049][ci] Make pre-downloaded Maven usable by the only-script Maven wrapper [flink] via GitHub
• 2026/10/22 Re: [PR] [FLINK-40135][python] Prevent Beam state access after runner shutdown [flink] via GitHub
• 2026/10/22 Re: [PR] [FLINK-37244] Added scylladb tests, documentation and README [flink-connector-cassandra] via GitHub
• 2026/10/22 [jira] [Updated] (FLINK-41054) Metrics of finished source splits are never removed from the REST API's metric store ASF GitHub Bot (Jira)
• 2026/10/22 [jira] [Comment Edited] (FLINK-41073) Checkpoint acknowledgement that fails shared state registration is dropped and the checkpoint waits for its timeout Shrey Bansal (Jira)
• 2026/10/22 [jira] [Resolved] (FLINK-41034) Streaming joins store rows with a NULL join key in state, even though they can never match Gustavo de Morais (Jira)
• 2026/10/22 [jira] [Commented] (FLINK-39996) Migrate KafkaSink EOS recovery to Kafka public PreparedTxnState API Martijn Visser (Jira)
• 2026/10/22 [jira] [Commented] (FLINK-41049) CI jobs fail when the downloaded Maven wrapper jar does not pass its SHA-256 check Sergey Nuyanzin (Jira)
• 2026/10/22 Re: [PR] [FLINK-41009][connector/pulsar] Use a single transaction per checkpoint [flink-connector-pulsar] via GitHub
• 2026/10/22 Re: [PR] [FLINK-33020][ci] OpensearchSinkTest.testAtLeastOnceSink timed out [flink-connector-opensearch] via GitHub
• 2026/10/22 [jira] [Assigned] (FLINK-40617) Connectors/Kafka: Prune and bump dependency versions in the root pom Martijn Visser (Jira)
• 2026/10/22 Re: [PR] [FLINK-40617][build] Prune and bump dependency versions in the root pom [flink-connector-kafka] via GitHub
• 2026/10/22 [jira] [Commented] (FLINK-33186) CheckpointAfterAllTasksFinishedITCase.testRestoreAfterSomeTasksFinished fails on AZP Efrat Levitan (Jira)
• 2026/10/22 Re: [PR] [FLINK-31006][Connectors/Kafka] Signal no more splits after a restored bounded enumerator finds no partition changes [flink-connector-kafka] via GitHub
• 2026/10/22 Re: [I] [Feature][chat-models] Support multimodal tool results in model provider adapters [flink-agents] via GitHub
• 2026/10/22 Re: [PR] [FLINK-40874][table] MiniBatch joins fix: join key-only deletes of suppressed pairs with the stored record [flink] via GitHub
• 2026/10/22 Re: [PR] [FLINK-41028] Support data lake table properties in the Fluss pipeline sink [flink-cdc] via GitHub
• 2026/10/22 [PR] [FLINK-40129][Connectors/Kafka] Topic integrity check in table API [flink-connector-kafka] via GitHub
• 2026/10/22 Re: [PR] [FLINK-40710][Connectors/Kafka] Preserve Dynamic Kafka partition ownership during reader recovery [flink-connector-kafka] via GitHub
• 2026/10/22 [jira] [Updated] (FLINK-40874) Mini-batch streaming join evaluates non-equi conditions on key-only deletes of folded pairs ASF GitHub Bot (Jira)
• 2026/10/22 [PR] [FLINK-40874][table] MiniBatch joins fix: join key-only deletes of suppressed pairs with the stored record [flink] via GitHub
• 2026/10/22 [jira] [Updated] (FLINK-39990) Expose DynamicKafkaSource.activeSplitCount metric per source reader Martijn Visser (Jira)
• 2026/10/22 [jira] [Updated] (FLINK-41088) DynamicKafkaSource loses or rejects splits whose formatted split ids collide ASF GitHub Bot (Jira)
• 2026/10/22 [PR] [FLINK-41088][Connectors/Kafka] Key recovery reports by partition [flink-connector-kafka] via GitHub
• 2026/10/22 [jira] [Commented] (FLINK-40065) flink-connector-aws: update flink-connector-parent to 2.0.0 and flink.version to 2.1. Muhammad (Jira)
• 2026/10/22 Re: [PR] [FLINK-40617][build] Prune and bump dependency versions in the root pom [flink-connector-kafka] via GitHub
• 2026/10/22 [jira] [Updated] (FLINK-40617) Connectors/Kafka: Prune and bump dependency versions in the root pom Martijn Visser (Jira)
• 2026/10/22 Re: [PR] [FLINK-40977][state/forst] Complete JUnit 5 migration of flink-statebackend-forst [flink] via GitHub
• 2026/10/22 [jira] [Commented] (FLINK-41073) Checkpoint acknowledgement that fails shared state registration is dropped and the checkpoint waits for its timeout Shrey Bansal (Jira)
• 2026/10/22 [jira] [Updated] (FLINK-24697) Kafka table source cannot change the auto.offset.reset setting for 'group-offsets' startup mode Martijn Visser (Jira)
• 2026/10/22 [jira] [Updated] (FLINK-40617) Connectors/Kafka: Prune and bump dependency versions in the root pom Martijn Visser (Jira)
• 2026/10/22 Re: [PR] [FLINK-40710][Connectors/Kafka] Preserve Dynamic Kafka partition ownership during reader recovery [flink-connector-kafka] via GitHub
• 2026/10/22 [jira] [Updated] (FLINK-39990) Expose DynamicKafkaSource.activeSplitCount metric per source reader Martijn Visser (Jira)
• 2026/10/22 Re: [PR] [FLINK-41068][table] Don't store build rows whose join key can never match in LATERAL SNAPSHOT joins [flink] via GitHub
• 2026/10/22 Re: [PR] [FLINK-31006][Connectors/Kafka] Signal no more splits after a restored bounded enumerator finds no partition changes [flink-connector-kafka] via GitHub
• 2026/10/22 Re: [PR] [FLINK-41068][table] Don't store build rows whose join key can never match in LATERAL SNAPSHOT joins [flink] via GitHub
• 2026/10/22 Re: [PR] [FLINK-36532][Connectors/Kafka] Commit offsets on stop-with-savepoint [flink-connector-kafka] via GitHub
• 2026/10/22 Re: [PR] [FLINK-31006][Connectors/Kafka] Signal no more splits after a restored bounded enumerator finds no partition changes [flink-connector-kafka] via GitHub
• 2026/10/22 [jira] [Created] (FLINK-41088) DynamicKafkaSource loses or rejects splits whose formatted split ids collide Martijn Visser (Jira)
• 2026/10/22 Re: [PR] [FLINK-37984] Cassandra Sink V2 Implementation (FLIP-533) (Phase-1) [flink-connector-cassandra] via GitHub
• 2026/10/22 Re: [PR] [FLINK-41070][Connectors/Cassandra] Test against Flink 1.19.3 [flink-connector-cassandra] via GitHub
• 2026/10/22 Re: [PR] [FLINK-41070][Connectors/Cassandra] Test against Flink 1.19.3 [flink-connector-cassandra] via GitHub
• 2026/10/22 Re: [PR] [FLINK-31006][Connectors/Kafka] Signal no more splits after a restored bounded enumerator finds no partition changes [flink-connector-kafka] via GitHub
• 2026/10/22 Re: [PR] [FLINK-31006][Connectors/Kafka] Signal no more splits after a restored bounded enumerator finds no partition changes [flink-connector-kafka] via GitHub
• 2026/10/22 Re: [PR] [FLINK-34468][Connector/Cassandra] Adding support for Flink 1.20 [flink-connector-cassandra] via GitHub
• 2026/10/22 Re: [PR] [FLINK-41068][table] Don't store build rows whose join key can never match in LATERAL SNAPSHOT joins [flink] via GitHub
• 2026/10/22 [jira] [Assigned] (FLINK-40874) Mini-batch streaming join evaluates non-equi conditions on key-only deletes of folded pairs Gustavo de Morais (Jira)
• 2026/10/22 Re: [PR] [FLINK-40710][Connectors/Kafka] Preserve Dynamic Kafka partition ownership during reader recovery [flink-connector-kafka] via GitHub
• 2026/10/22 [jira] [Assigned] (FLINK-40874) Mini-batch streaming join evaluates non-equi conditions on key-only deletes of folded pairs Gustavo de Morais (Jira)
• 2026/10/22 Re: [PR] [FLINK-40710][Connectors/Kafka] Preserve Dynamic Kafka partition ownership during reader recovery [flink-connector-kafka] via GitHub
• 2026/10/22 [jira] [Assigned] (FLINK-41067) Window and interval joins store rows whose join key can never match Gustavo de Morais (Jira)
• 2026/10/22 [jira] [Assigned] (FLINK-41066) MultiJoin produces wrong results when an upsert input replaces a record without UPDATE_BEFORE Gustavo de Morais (Jira)
• 2026/10/22 [jira] [Assigned] (FLINK-40842) Streaming semi/anti join over-counts matches for right-side updates without UPDATE_BEFORE Gustavo de Morais (Jira)
• 2026/10/22 [jira] [Assigned] (FLINK-41068) LATERAL SNAPSHOT join stores build-side rows whose join key can never match Gustavo de Morais (Jira)
• 2026/10/22 [jira] [Updated] (FLINK-40121) Update Flink Connector Kafka to use Flink 2.3 Martijn Visser (Jira)
• 2026/10/22 [jira] [Updated] (FLINK-39888) [Kafka] Allow configuring offset reset strategy independently of startup offsets Martijn Visser (Jira)
• 2026/10/22 [jira] [Updated] (FLINK-39940) DynamicKafkaSource should refresh restored cluster properties from KafkaMetadataService Martijn Visser (Jira)
• 2026/10/22 Re: [PR] [FLINK-41065][table] Allow process table functions to exclude state entries per call [flink] via GitHub
• 2026/10/22 [jira] [Updated] (FLINK-40367) Make Kafka consumer poll timeout configurable Martijn Visser (Jira)
• 2026/10/22 [PR] [FLINK-40121][Connectors/Kafka] Build and test against Flink 2.3 [flink-connector-kafka] via GitHub
• 2026/10/22 [jira] [Updated] (FLINK-33497) Update the Kafka connector to support DISTRIBUTED BY clause Martijn Visser (Jira)
• 2026/10/22 [jira] [Updated] (FLINK-37818) Kafka connector requires unqiue TransactionalIdPrefix even for non-EOS settings. Martijn Visser (Jira)
• 2026/10/22 [jira] [Updated] (FLINK-39712) Fix flaky DynamicKafkaSourceITTest Martijn Visser (Jira)
• 2026/10/22 [jira] [Updated] (FLINK-41065) Improve TypeInferenceUtil for built-in PTFs ASF GitHub Bot (Jira)
• 2026/10/22 [PR] [FLINK-41065][table] Allow process table functions to exclude state entries per call [flink] via GitHub
• 2026/10/22 [jira] [Updated] (FLINK-38287) Kafka 4.1.0 Queue Semantics support in Flink Connector Kafka Martijn Visser (Jira)
• 2026/10/22 [jira] [Updated] (FLINK-38530) create Dynamic Kafka Source for pyflink Martijn Visser (Jira)
• 2026/10/22 [jira] [Updated] (FLINK-38919) add doc of pyflink DynamicKafkaSource per cluster offset feature to flink-connector-kafka Martijn Visser (Jira)
• 2026/10/22 [jira] [Updated] (FLINK-30932) Enabling producer metrics for KafkaSink is not documented Martijn Visser (Jira)
• 2026/10/22 [jira] [Updated] (FLINK-25509) FLIP-208: Add RecordEvaluator to dynamically stop source based on de-serialized records Martijn Visser (Jira)
• 2026/10/22 [jira] [Assigned] (FLINK-33497) Update the Kafka connector to support DISTRIBUTED BY clause Martijn Visser (Jira)
• 2026/10/22 [jira] [Updated] (FLINK-40121) Update Flink Connector Kafka to use Flink 2.3 Martijn Visser (Jira)
• 2026/10/22 [jira] [Updated] (FLINK-39940) DynamicKafkaSource should refresh restored cluster properties from KafkaMetadataService Martijn Visser (Jira)
• 2026/10/22 [jira] [Updated] (FLINK-33484) Flink Kafka Connector Offset Lag Issue with Transactional Data and Read Committed Isolation Level Martijn Visser (Jira)
• 2026/10/22 [jira] [Updated] (FLINK-40469) DynamicKafkaSource can lose splits when checkpointing during recovery reassignment Martijn Visser (Jira)
• 2026/10/22 [jira] [Updated] (FLINK-39837) Make dynamic Kafka source resilient for Kafka topology instability Martijn Visser (Jira)
• 2026/10/22 [jira] [Updated] (FLINK-40128) Implement Topic integrity checks in Kafka Connector - Static source Martijn Visser (Jira)
• 2026/10/22 [jira] [Updated] (FLINK-39608) KafkaDatasetFacet should extend DatasetConfigFacet to avoid classloader issues with OpenLineage Martijn Visser (Jira)
• 2026/10/22 [jira] [Updated] (FLINK-39792) Add multi-headers metadata key to Kafka connector Martijn Visser (Jira)
• 2026/10/22 [jira] [Updated] (FLINK-39996) Migrate KafkaSink EOS recovery to Kafka public PreparedTxnState API Martijn Visser (Jira)
• 2026/10/22 [jira] [Commented] (FLINK-33497) Update the Kafka connector to support DISTRIBUTED BY clause Martijn Visser (Jira)
• 2026/10/22 [jira] [Updated] (FLINK-39712) Fix flaky DynamicKafkaSourceITTest Martijn Visser (Jira)
• 2026/10/22 [jira] [Updated] (FLINK-40847) KafkaDynamicSink#equals/hashCode ignore transactionNamingStrategy Martijn Visser (Jira)
• 2026/10/22 [jira] [Updated] (FLINK-40367) Make Kafka consumer poll timeout configurable Martijn Visser (Jira)
• 2026/10/22 [jira] [Updated] (FLINK-39980) Implement split rebalance/reassignment support in DynamicKafkaSource after metadata changes Martijn Visser (Jira)
• 2026/10/22 [jira] [Updated] (FLINK-39608) KafkaDatasetFacet should extend DatasetConfigFacet to avoid classloader issues with OpenLineage Martijn Visser (Jira)
• 2026/10/22 [jira] [Updated] (FLINK-39888) [Kafka] Allow configuring offset reset strategy independently of startup offsets Martijn Visser (Jira)
• 2026/10/22 [jira] [Updated] (FLINK-39944) Dynamic Kafka source cluster removal is not resilient enough Martijn Visser (Jira)
• 2026/10/22 [jira] [Updated] (FLINK-39979) DynamicKafkaSource should mark reader idle when metadata removal leaves a subtask with no active subreaders Martijn Visser (Jira)
• 2026/10/22 [jira] [Updated] (FLINK-39837) Make dynamic Kafka source resilient for Kafka topology instability Martijn Visser (Jira)
• 2026/10/22 [jira] [Updated] (FLINK-39892) Exactly-once kafka sink reports a negative numBytesOut delta after every checkpoint Martijn Visser (Jira)
• 2026/10/22 [PR] [runtime] Bound continuation inputs and prioritize queued async work by record start order [flink-agents] via GitHub
• 2026/10/22 [jira] [Updated] (FLINK-41068) LATERAL SNAPSHOT join stores build-side rows whose join key can never match ASF GitHub Bot (Jira)
• 2026/10/22 [PR] [FLINK-41068][table] Don't store build rows whose join key can never match in LATERAL SNAPSHOT joins [flink] via GitHub
• 2026/10/22 Re: [PR] [FLINK-41068][table] Don't store build rows whose join key can never match in LATERAL SNAPSHOT joins [flink] via GitHub
• 2026/10/22 [jira] [Assigned] (FLINK-40121) Update Flink Connector Kafka to use Flink 2.3 Martijn Visser (Jira)
• 2026/10/22 [jira] [Updated] (FLINK-40121) Update Flink Connector Kafka to use Flink 2.3 Martijn Visser (Jira)
• 2026/10/22 [jira] [Updated] (FLINK-40121) Update Flink Connector Kafka to use Flink 2.3 Martijn Visser (Jira)
• 2026/10/22 [jira] [Commented] (FLINK-34224) ChangelogStorageMetricsTest.testAttemptsPerUpload(ChangelogStorageMetricsTest timed out Rakesh kumar (Jira)
• 2026/10/22 Re: [PR] [FLINK-41076] Bump Jackson to 2.21.8 (release-21.0) [flink-shaded] via GitHub
• 2026/10/22 Re: [PR] [FLINK-41076] Bump Jackson to 2.21.8 (release-21.0) [flink-shaded] via GitHub
• 2026/10/22 Re: [PR] [FLINK-41076] Bump Netty to 4.2.19.Final (release-21.0) [flink-shaded] via GitHub
• 2026/10/22 Re: [PR] [FLINK-41076] Bump ZooKeeper to 3.8.7 (release-21.0) [flink-shaded] via GitHub
• 2026/10/22 Re: [PR] [runtime][java] Preserve an existing KeyedStream's business key when no key selector is given [flink-agents] via GitHub
• 2026/10/22 Re: [PR] [FLINK-40216][cdc-base] Preserve assignment order of splits across restore to keep meta groups consistent [flink-cdc] via GitHub
• 2026/10/22 [jira] [Updated] (FLINK-38323) Global Scale Factor Mode Salva (Jira)
• 2026/10/22 [jira] [Updated] (FLINK-40582) Add SCHEMA_OF_VARIANT and SCHEMA_OF_VARIANT_AGG built-in functions Ramin Gharib (Jira)

• Earlier messages
• Later messages