issues  

Messages by Date

• 2026/10/23 Re: [PR] [FLINK-41028] Support data lake table properties in the Fluss pipeline sink [flink-cdc] via GitHub
• 2026/10/23 [jira] [Comment Edited] (FLINK-41105) transform projection: arithmetic between DECIMAL column and numeric literal fails at Janino compile time — times(BigDecimal, double) has no matching overload zhanglu153 (Jira)
• 2026/10/23 [I] [Feature] Add LiteLLM Router SDK integration for model routing and failover [flink-agents] via GitHub
• 2026/10/23 [jira] [Created] (FLINK-41106) MapState.put_all() iterates dictionary keys instead of key-value pairs Dian Fu (Jira)
• 2026/10/23 [jira] [Commented] (FLINK-41105) transform projection: arithmetic between DECIMAL column and numeric literal fails at Janino compile time — times(BigDecimal, double) has no matching overload zhanglu153 (Jira)
• 2026/10/23 Re: [PR] [hotfix][ci] Pin all runner images at Ubuntu 24.04 [flink-cdc] via GitHub
• 2026/10/23 [jira] [Created] (FLINK-41105) transform projection: arithmetic between DECIMAL column and numeric literal fails at Janino compile time — times(BigDecimal, double) has no matching overload zhanglu153 (Jira)
• 2026/10/23 Re: [PR] [FLINK-36299][runtime] Start scheduling and offer the slot in one main-thread task in AdaptiveSchedulerTest.testStatusMetrics [flink] via GitHub
• 2026/10/23 [PR] [hotfix][ci] Reduce rescaling test logs and align Java IT [flink-agents] via GitHub
• 2026/10/23 Re: [PR] [FLINK-40807][table] Add XML_STRING function [flink] via GitHub
• 2026/10/23 Re: [I] [Bug][runtime][java][python] Model-driven subagent await failures leave pending handles and fail the action [flink-agents] via GitHub
• 2026/10/23 Re: [PR] [runtime][java][python] Release subagent handles after await failures [flink-agents] via GitHub
• 2026/10/23 [jira] [Created] (FLINK-41104) MapState.contains() returns false for an existing key whose value is None Dian Fu (Jira)
• 2026/10/23 [jira] [Created] (FLINK-41103) ValueState.update(None) attempts to serialize None instead of clearing the state Dian Fu (Jira)
• 2026/10/23 Re: [PR] [hotfix][ci] Remove disallowed markdown link check action from docs workflow for release-3.7 [flink-cdc] via GitHub
• 2026/10/23 [jira] [Commented] (FLINK-37607) Blocklist timeout check may lost Lei Yang (Jira)
• 2026/10/23 [PR] [hotfix][ci] Remove disallowed markdown link check action from docs workflow for release-3.7 [flink-cdc] via GitHub
• 2026/10/23 [jira] [Created] (FLINK-41102) Keyed state clear operations are lost on key changes when python.state.cache-size is zero Dian Fu (Jira)
• 2026/10/23 Re: [PR] [BP-3.6][FLINK-39573][docs] Fix Build documentation CI for release-3.6 [flink-cdc] via GitHub
• 2026/10/23 Re: [D] Flink Agents Release Process [flink-agents] via GitHub
• 2026/10/23 Re: [PR] [hotfix][docs] Centralize stable release versions in setup examples [flink-agents] via GitHub
• 2026/10/23 [jira] [Commented] (FLINK-40958) VARIANT might fail with StackOverflow Martijn Visser (Jira)
• 2026/10/23 [jira] [Commented] (FLINK-41060) Exactly-once JdbcSink commits its XA branch at the checkpoint barrier Martijn Visser (Jira)
• 2026/10/23 [jira] [Created] (FLINK-41101) discoverAndRollbackOnRecovery never rolls back a transaction against a real driver Martijn Visser (Jira)
• 2026/10/23 [jira] [Updated] (FLINK-34495) Resuming Savepoint (rocks, scale up, heap timers) end-to-end test failure due to FileNotFoundException Martijn Visser (Jira)
• 2026/10/22 Re: [PR] [FLINK-40655][tests] Run deployment callbacks inline in ExecutionVertexTest [flink] via GitHub
• 2026/10/22 [jira] [Updated] (FLINK-29898) ClusterEntrypointTest.testCloseAsyncShouldBeExecutedInShutdownHook fails on CI Martijn Visser (Jira)
• 2026/10/22 [jira] [Assigned] (FLINK-41100) DynamicKafkaSource shares one split output between partitions whose split ids collide Martijn Visser (Jira)
• 2026/10/22 Re: [PR] [FLINK-41088][Connectors/Kafka] Key recovery reports by partition [flink-connector-kafka] via GitHub
• 2026/10/22 [jira] [Updated] (FLINK-41088) DynamicKafkaSource loses or rejects splits whose formatted split ids collide Martijn Visser (Jira)
• 2026/10/22 Re: [PR] [runtime][java][python] Release subagent handles after await failures [flink-agents] via GitHub
• 2026/10/22 [jira] [Updated] (FLINK-41100) DynamicKafkaSource shares one split output between partitions whose split ids collide Martijn Visser (Jira)
• 2026/10/22 [jira] [Commented] (FLINK-34523) Some jar couldn't be downloaded from google-maven-central Martijn Visser (Jira)
• 2026/10/22 [jira] [Commented] (FLINK-26644) python StreamExecutionEnvironmentTests.test_generate_stream_graph_with_dependencies failed on azure Martijn Visser (Jira)
• 2026/10/22 [jira] [Reopened] (FLINK-29898) ClusterEntrypointTest.testCloseAsyncShouldBeExecutedInShutdownHook fails on CI Martijn Visser (Jira)
• 2026/10/22 [jira] [Updated] (FLINK-35710) ClusterEntrypointTest failed on AZP due to exit code: 239 Martijn Visser (Jira)
• 2026/10/22 [jira] [Commented] (FLINK-35710) ClusterEntrypointTest failed on AZP due to exit code: 239 Martijn Visser (Jira)
• 2026/10/22 [jira] [Commented] (FLINK-39954) SinkV2ITCase over-asserts commit multiplicity under unaligned checkpoints Martijn Visser (Jira)
• 2026/10/22 [jira] [Updated] (FLINK-41100) DynamicKafkaSource shares one split output between partitions whose split ids collide Martijn Visser (Jira)
• 2026/10/22 [jira] [Commented] (FLINK-33186) CheckpointAfterAllTasksFinishedITCase.testRestoreAfterSomeTasksFinished fails on AZP Martijn Visser (Jira)
• 2026/10/22 [jira] [Commented] (FLINK-34495) Resuming Savepoint (rocks, scale up, heap timers) end-to-end test failure due to FileNotFoundException Martijn Visser (Jira)
• 2026/10/22 [jira] [Updated] (FLINK-41100) DynamicKafkaSource shares one split output between partitions whose split ids collide Martijn Visser (Jira)
• 2026/10/22 [PR] [FLINK-40655][tests] Run deployment callbacks inline in ExecutionVertexTest [flink] via GitHub
• 2026/10/22 [jira] [Created] (FLINK-41100) DynamicKafkaSource shares one split output between partitions whose split ids collide Martijn Visser (Jira)
• 2026/10/22 [jira] [Updated] (FLINK-41100) DynamicKafkaSource shares one split output between partitions whose split ids collide Martijn Visser (Jira)
• 2026/10/22 [jira] [Commented] (FLINK-33186) CheckpointAfterAllTasksFinishedITCase.testRestoreAfterSomeTasksFinished fails on AZP Martijn Visser (Jira)
• 2026/10/22 [I] [Tech Debt][runtime][java][python] Clarify subagent group cleanup and internal fault propagation [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-33186][tests] Re-disable periodic checkpoints in CheckpointAfterAllTasksFinishedITCase tests [flink] via GitHub
• 2026/10/22 Re: [PR] [runtime][java][python] Release subagent handles after await failures [flink-agents] via GitHub
• 2026/10/22 Re: [PR] [runtime][java][python] Release subagent handles after await failures [flink-agents] via GitHub
• 2026/10/22 Re: [PR] [FLINK-38689] [flink-protobuf] Add support for protobuf 4.x field name conflict resolution [flink] via GitHub
• 2026/10/22 Re: [PR] [FLINK-40977][state/forst] Complete JUnit 5 migration of flink-statebackend-forst [flink] via GitHub
• 2026/10/22 [jira] [Resolved] (FLINK-40977) ForSt JUnit 5 migration is incomplete Martijn Visser (Jira)
• 2026/10/22 [jira] [Resolved] (FLINK-38574) Avoid reusing re-uploaded sst files when checkpoint notification is delayed Martijn Visser (Jira)
• 2026/10/22 Re: [PR] [runtime][java][python] Release subagent handles after await failures [flink-agents] 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 [jira] [Commented] (FLINK-38574) Avoid reusing re-uploaded sst files when checkpoint notification is delayed Martijn Visser (Jira)
• 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: [PR] [FLINK-41076] Bump netty-tcnative to 2.0.84.Final (release-21.0) [flink-shaded] 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: [PR] [FLINK-34625][python] Fix state TTL read cache disabling [flink] via GitHub
• 2026/10/22 [PR] [hotfix][ci] Pin all runner images at Ubuntu 24.04 [flink-cdc] via GitHub
• 2026/10/22 [PR] [FLINK-41076] Bump netty-tcnative to 2.0.84.Final (release-21.0) [flink-shaded] via GitHub
• 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

• Earlier messages
• Later messages