issues  

Messages by Date

• 2026/10/22 [jira] [Created] (FLINK-41086) JSON_LENGTH and JSON_TYPE fail the job when a JSON path function throws Ramin Gharib (Jira)
• 2026/10/22 [PR] [FLINK-41076] Bump ZooKeeper to 3.8.7 (release-21.0) [flink-shaded] via GitHub
• 2026/10/22 [jira] [Updated] (FLINK-41076) Bump Netty, Jackson and ZooKeeper in flink-shaded release-21.0 Purushottam Sinha (Jira)
• 2026/10/22 Re: [PR] [runtime][python][docs] Fix execution guards and observability gaps in Operations guidance [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 [jira] [Updated] (FLINK-41076) Bump Netty to 4.2.19.Final and Jackson to 2.21.8 in flink-shaded release-21.0 Purushottam Sinha (Jira)
• 2026/10/22 [PR] [FLINK-41061] Reduce sleep frequency of adaptive partition selection benchmark [flink-benchmarks] via GitHub
• 2026/10/22 [jira] [Updated] (FLINK-41061) Daily benchmark keeps failing because of excessive runtime of the adaptive partition benchmark ASF GitHub Bot (Jira)
• 2026/10/22 Re: [PR] [FLINK-41059][runtime] Schedule slot manager work on the main thread [flink] via GitHub
• 2026/10/22 Re: [PR] [FLINK-41077][rpc] Rethrow scheduled task failures in the main thread [flink] via GitHub
• 2026/10/22 [jira] [Updated] (FLINK-41059) FineGrainedSlotManager schedules requirement checks into the main thread after suspend() ASF GitHub Bot (Jira)
• 2026/10/22 [PR] [FLINK-41059][runtime] Schedule slot manager work on the main thread [flink] via GitHub
• 2026/10/22 [jira] [Updated] (FLINK-41077) RpcEndpoint.MainThreadExecutor#schedule swallows exceptions thrown by the scheduled task ASF GitHub Bot (Jira)
• 2026/10/22 [PR] [FLINK-41077][rpc] Rethrow scheduled task failures in the main thread [flink] via GitHub
• 2026/10/22 Re: [PR] [FLINK-40943][filesystems] Restore FileSink state written with flink-s3-fs-hadoop in flink-s3-fs-native [flink] via GitHub
• 2026/10/22 [jira] [Created] (FLINK-41080) [UMBRELLA] Polish Flink CDC docs and enrich contents Xiqian Yu (Jira)
• 2026/10/22 Re: [PR] [FLINK-41082] Polish Flink CDC docs and fix format issues [flink-cdc] via GitHub
• 2026/10/22 [jira] [Created] (FLINK-41085) AppendOnlyTopNFunction emits an inconsistent changelog after cache eviction when sorting on NaN Bettle (Jira)
• 2026/10/22 [jira] [Updated] (FLINK-40318) Add a validation entry point for a VARIANT binary Ramin Gharib (Jira)
• 2026/10/22 Re: [I] [Bug][runtime] ID-based get/delete can access items outside the calling MemorySet [flink-agents] via GitHub
• 2026/10/22 Re: [PR] [FLINK-37027][docs] Translate TO_TIMESTAMP_LTZ descriptions [flink] via GitHub
• 2026/10/21 Re: [PR] [FLINK-33186][tests] Re-disable periodic checkpoints in CheckpointAfterAllTasksFinishedITCase tests [flink] via GitHub
• 2026/10/21 Re: [PR] [docs][python] Fix setup, Quickstart and scalar Table output [flink-agents] via GitHub
• 2026/10/21 [PR] [hotfix][docs] Correct Debezium version in DataStream API package guidance [flink-cdc] via GitHub
• 2026/10/21 Re: [PR] [hotfix][docs] Correct Debezium version in DataStream API package guidance [flink-cdc] via GitHub
• 2026/10/21 Re: [PR] [hotfix][docs] Correct Debezium version in DataStream API package guidance [flink-cdc] via GitHub
• 2026/10/21 [jira] [Commented] (FLINK-40915) Relax non-deterministic join-condition check for LATERAL SNAPSHOT join ChenZhuo (Jira)
• 2026/10/21 Re: [PR] [FLINK-37027][docs] Translate TO_TIMESTAMP_LTZ descriptions [flink] via GitHub
• 2026/10/21 Re: [PR] [FLINK-38144][state] Fix changelog state backend NPE with null map state values [flink] via GitHub
• 2026/10/21 [PR] [hotfix][docs] Correct Debezium version in DataStream API package guidance [flink-cdc] via GitHub
• 2026/10/21 Re: [PR] [FLINK-38144][state] Fix changelog state backend NPE with null map state values [flink] via GitHub
• 2026/10/21 [PR] Bump @vitest/mocker and vitest in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/10/21 Re: [PR] [FLINK-40943][filesystems] Restore FileSink state written with flink-s3-fs-hadoop in flink-s3-fs-native [flink] via GitHub
• 2026/10/21 Re: [PR] [BP-1.20][FLINK-38574][checkpoint] Avoid reusing re-uploaded sst files when checkpoint notification is delayed [flink] via GitHub
• 2026/10/21 Re: [PR] Bump certifi from 2026.1.4 to 2026.10.19 in /flink-python/docs [flink] via GitHub
• 2026/10/21 Re: [PR] [FLINK-41082] Polish Flink CDC docs and fix format issues [flink-cdc] via GitHub
• 2026/10/21 Re: [PR] [runtime][python] Handle missing long-term memory IDs [flink-agents] via GitHub
• 2026/10/21 Re: [PR] [FLINK-41057][iceberg] Fix append-only update and delete handling [flink-cdc] via GitHub
• 2026/10/21 Re: [PR] Bump @vitest/mocker and vitest in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/10/21 [jira] [Commented] (FLINK-41061) Daily benchmark keeps failing because of excessive runtime of the adaptive partition benchmark Han Yin (Jira)
• 2026/10/21 Re: [I] [Bug][runtime] Awaiting an internal sub-agent can deadlock by holding a shared async-pool worker [flink-agents] via GitHub
• 2026/10/21 Re: [PR] [runtime] Support subgraph execution on the non-coroutine parallel engine [flink-agents] via GitHub
• 2026/10/21 [jira] [Commented] (FLINK-41061) Daily benchmark keeps failing because of excessive runtime of the adaptive partition benchmark Yuepeng Pan (Jira)
• 2026/10/21 [PR] [api][integrations][java][python] Reject a blank model in chat model setups [flink-agents] via GitHub
• 2026/10/21 Re: [I] [Bug][runtime] Continuation execution ignores max-in-flight-input-records on JDK 21 [flink-agents] via GitHub
• 2026/10/21 Re: [PR] [FLINK-41057][iceberg] Fix append-only update and delete handling [flink-cdc] via GitHub
• 2026/10/21 [jira] [Commented] (FLINK-40804) UnalignedCheckpointRescaleWithMixedExchangesITCase.testRescaleFromUnalignedCheckpoint fails with "Exceeded checkpoint tolerable failure threshold" Gunjan Aggarwal (Jira)
• 2026/10/21 Re: [PR] [runtime] Enforce continuation input limits and prioritize earlier runs [flink-agents] via GitHub
• 2026/10/21 [PR] [docs][python] Fix setup, Quickstart and scalar Table output [flink-agents] via GitHub
• 2026/10/21 [PR] [runtime] Enforce continuation input limits and prioritize earlier runs [flink-agents] via GitHub
• 2026/10/21 [jira] [Updated] (FLINK-41082) Polish Flink CDC docs and fix format issues ASF GitHub Bot (Jira)
• 2026/10/21 [PR] [FLINK-41082] Polish Flink CDC docs and fix format issues [flink-cdc] via GitHub
• 2026/10/21 [jira] [Created] (FLINK-41084) Common & Source-Specific Metrics sukang (Jira)
• 2026/10/21 [jira] [Resolved] (FLINK-40192) Add as-of join support to DataFrame API Dian Fu (Jira)
• 2026/10/21 Re: [PR] [FLINK-40192][python] Add as-of join support to DataFrame API [flink] via GitHub
• 2026/10/21 Re: [PR] Flink 34224 [flink] via GitHub
• 2026/10/21 Re: [PR] [FLINK-40957][connect/mongodb] Fix MongoDB credential encoding for spaces [flink-cdc] via GitHub
• 2026/10/21 [PR] Flink 34224 [flink] via GitHub
• 2026/10/21 Re: [PR] [FLINK-40957][connect/mongodb] Fix MongoDB credential encoding for spaces [flink-cdc] via GitHub
• 2026/10/21 Re: [PR] [FLINK-40898][table-planner] Allow non-deterministic filters in ChangelogNormalize [flink] via GitHub
• 2026/10/21 [jira] [Created] (FLINK-41083) Add quickstart examples and best practice for Flink CDC docs Xiqian Yu (Jira)
• 2026/10/21 Re: [I] [Bug][runtime] Continuation execution ignores max-in-flight-input-records on JDK 21 [flink-agents] via GitHub
• 2026/10/21 [jira] [Created] (FLINK-41082) Polish Flink CDC docs and fix format issues Xiqian Yu (Jira)
• 2026/10/21 [jira] [Created] (FLINK-41081) Provide EN / ZH bilingual docs for Flink CDC Xiqian Yu (Jira)
• 2026/10/21 Re: [I] [Doc] Walkthrough findings for Setup, multi-Agent Quickstart and Flink integration [flink-agents] via GitHub
• 2026/10/21 [PR] [runtime][python] Handle missing long-term memory IDs [flink-agents] via GitHub
• 2026/10/21 Re: [PR] [docs] Correct memory documentation [flink-agents] via GitHub
• 2026/10/21 Re: [I] [Doc] Walkthrough findings for Setup, multi-Agent Quickstart and Flink integration [flink-agents] via GitHub
• 2026/10/21 Re: [PR] [FLINK-40957][connect/mongodb] Fix MongoDB credential encoding for spaces [flink-cdc] via GitHub
• 2026/10/21 Re: [I] [Bug][runtime] ID-based get/delete can access items outside the calling MemorySet [flink-agents] via GitHub
• 2026/10/21 Re: [I] [Bug][runtime][java][python] Model-driven subagent await failures leave pending handles and fail the action [flink-agents] via GitHub
• 2026/10/21 Re: [I] [Bug][runtime] ActionStateStore misclassifies normal multi-Action execution as divergence [flink-agents] via GitHub
• 2026/10/21 Re: [PR] [runtime] Fix ActionStateStore divergence detection for multi-action replay [flink-agents] via GitHub
• 2026/10/21 [jira] [Commented] (FLINK-34224) ChangelogStorageMetricsTest.testAttemptsPerUpload(ChangelogStorageMetricsTest timed out Rakesh kumar (Jira)
• 2026/10/21 Re: [PR] [docs] Correct memory documentation [flink-agents] via GitHub
• 2026/10/21 Re: [PR] [docs] Correct memory documentation [flink-agents] via GitHub
• 2026/10/21 [I] [Bug][runtime] ID-based get/delete can access items outside the calling MemorySet [flink-agents] via GitHub
• 2026/10/21 Re: [I] [Bug][runtime] An input that triggers no Actions can strand the next input queued for the same key [flink-agents] via GitHub
• 2026/10/21 Re: [PR] [runtime] Process the input queued behind an input that triggers no Actions [flink-agents] via GitHub
• 2026/10/21 [PR] [runtime][java] Preserve an existing KeyedStream's business key when no key selector is given [flink-agents] via GitHub
• 2026/10/21 Re: [PR] [FLINK-40717][connectors/mongodb] Add AGENTS.md and PR template with AI disclosure [flink-connector-mongodb] via GitHub
• 2026/10/21 [PR] [runtime] Process the input queued behind an input that triggers no Actions [flink-agents] via GitHub
• 2026/10/21 Re: [PR] [FLINK-41075][ci] Kill each e2e timeout watchdog when its command ends [flink] via GitHub
• 2026/10/21 [jira] [Created] (FLINK-41076) Bump Netty to 4.2.17.Final in flink-shaded release-21.0 Purushottam Sinha (Jira)
• 2026/10/21 [jira] [Updated] (FLINK-41079) Web dashboard: Update Angular to v22 and ng-zorro-antd to v22 ASF GitHub Bot (Jira)
• 2026/10/21 [PR] [FLINK-41076] Bump Jackson to 2.21.5 (release-21.0) [flink-shaded] via GitHub
• 2026/10/21 Re: [PR] [FLINK-41078][runtime] Complete slot manager debounce futures on failure [flink] via GitHub
• 2026/10/21 [jira] [Updated] (FLINK-41067) Window and interval joins store rows whose join key can never match ASF GitHub Bot (Jira)
• 2026/10/21 Re: [PR] [BP-1.20][FLINK-41053][test] Backport MAX_RETAINED_CHECKPOINTS fix to UnalignedCheckpointRescaleWithMixedExchangesITCase [flink] via GitHub
• 2026/10/21 Re: [PR] [FLINK-37987][jdbc] Migrate JdbcDynamicTableSink to Sink V2 [flink-connector-jdbc] via GitHub
• 2026/10/21 [jira] [Updated] (FLINK-41078) FineGrainedSlotManager stops scheduling delayed checks after one of them threw ASF GitHub Bot (Jira)
• 2026/10/21 [PR] [FLINK-41078][runtime] Complete slot manager debounce futures on failure [flink] via GitHub
• 2026/10/21 [jira] [Updated] (FLINK-41078) FineGrainedSlotManager stops scheduling delayed checks after one of them threw Martijn Visser (Jira)
• 2026/10/21 [jira] [Commented] (FLINK-34589) FineGrainedSlotManager doesn't handle errors in the resource reconcilliation step Martijn Visser (Jira)
• 2026/10/21 Re: [PR] [FLINK-41067][table] Don't store rows whose join key can never match in window and interval joins [flink] via GitHub
• 2026/10/21 [PR] [FLINK-41067][table] Don't store rows whose join key can never match in window and interval joins [flink] via GitHub
• 2026/10/21 [jira] [Updated] (FLINK-41076) Bump Netty to 4.2.17.Final and Jackson to 2.21.5 in flink-shaded release-21.0 Purushottam Sinha (Jira)
• 2026/10/21 [jira] [Assigned] (FLINK-41049) CI jobs fail when the downloaded Maven wrapper jar does not pass its SHA-256 check Martijn Visser (Jira)
• 2026/10/21 Re: [PR] [BP-2.3][FLINK-40904][FLINK-40780][runtime] Detect FORWARD parallelism mismatch correctly and make the downgrade configurable [flink] via GitHub
• 2026/10/21 Re: [PR] Bump @modelcontextprotocol/sdk, @angular-eslint/builder, @angular-eslint/schematics, @angular/cli and angular-eslint in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/10/21 Re: [PR] [FLINK-41079][runtime-web] Update Angular to v22 and ng-zorro-antd to v22 [flink] via GitHub
• 2026/10/21 [jira] [Updated] (FLINK-41049) CI jobs fail when the downloaded Maven wrapper jar does not pass its SHA-256 check ASF GitHub Bot (Jira)
• 2026/10/21 [PR] [FLINK-41079][runtime-web] Update Angular to v22 and ng-zorro-antd to v22 [flink] via GitHub
• 2026/10/21 [jira] [Created] (FLINK-41079) Web dashboard: Update Angular to v22 and ng-zorro-antd to v22 Purushottam Sinha (Jira)
• 2026/10/21 Re: [PR] [FLINK-41048][container] Fix MiniClusterJobEntryPointITCase race condition [flink] via GitHub
• 2026/10/21 [jira] [Created] (FLINK-41078) FineGrainedSlotManager stops scheduling delayed checks after one of them threw Martijn Visser (Jira)
• 2026/10/21 [jira] [Created] (FLINK-41077) RpcEndpoint.MainThreadExecutor#schedule swallows exceptions thrown by the scheduled task Martijn Visser (Jira)
• 2026/10/21 [jira] [Updated] (FLINK-41076) Bump Netty to 4.2.17.Final and Jackson to 2.21.5 in flink-shaded release-21.0 Purushottam Sinha (Jira)
• 2026/10/21 [jira] [Updated] (FLINK-41076) Bump Netty to 4.2.17.Final in flink-shaded release-21.0 ASF GitHub Bot (Jira)
• 2026/10/21 [PR] [FLINK-41076] Bump Netty to 4.2.17.Final (release-21.0) [flink-shaded] via GitHub
• 2026/10/21 [jira] [Comment Edited] (FLINK-38770) pipeline.jobvertex-parallelism-overrides ignored for StreamGraph in Application Mode Mika Naylor (Jira)
• 2026/10/21 [jira] [Updated] (FLINK-41075) Kill each e2e timeout watchdog when its command ends ASF GitHub Bot (Jira)
• 2026/10/21 [PR] [FLINK-41075][ci] Kill each e2e timeout watchdog when its command ends [flink] via GitHub
• 2026/10/21 [jira] [Created] (FLINK-41075) Kill each e2e timeout watchdog when its command ends Sergey Nuyanzin (Jira)
• 2026/10/21 Re: [PR] [FLINK-40977][state/forst] Complete JUnit 5 migration of flink-statebackend-forst [flink] via GitHub
• 2026/10/21 [jira] [Updated] (FLINK-41074) Blue/green deployment can retire the active deployment using readiness from an older candidate revision ASF GitHub Bot (Jira)
• 2026/10/21 [jira] [Created] (FLINK-41074) Blue/green deployment can retire the active deployment using readiness from an older candidate revision Luca Castelli (Jira)
• 2026/10/21 [PR] [FLINK-41074] Fence blue/green readiness to candidate generations [flink-kubernetes-operator] via GitHub
• 2026/10/21 Re: [PR] Bump @modelcontextprotocol/sdk, @angular-eslint/builder, @angular-eslint/schematics, @angular/cli and angular-eslint in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/10/21 Re: [PR] Bump certifi from 2026.1.4 to 2026.10.19 in /flink-python/docs [flink] via GitHub
• 2026/10/21 [jira] [Assigned] (FLINK-41062) PARSE_XML and TRY_PARSE_XML can run out of memory for large documents Ramin Gharib (Jira)
• 2026/10/21 [jira] [Assigned] (FLINK-34224) ChangelogStorageMetricsTest.testAttemptsPerUpload(ChangelogStorageMetricsTest timed out Mika Naylor (Jira)
• 2026/10/21 [PR] Bump certifi from 2026.1.4 to 2026.10.19 in /flink-python/docs [flink] via GitHub
• 2026/10/21 [jira] [Resolved] (FLINK-40098) Add FailingCheckpointedSource test utility for exactly-once source tests Martijn Visser (Jira)
• 2026/10/21 [PR] Bump @modelcontextprotocol/sdk, @angular-eslint/builder, @angular-eslint/schematics, @angular/cli and angular-eslint in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/10/21 Re: [PR] [FLINK-40098][test-utils] Add FailingCheckpointedSource for exactly-once source tests [flink] via GitHub
• 2026/10/21 [PR] [FLINK-41070][Connectors/Cassandra] Test against Flink 1.19.3 [flink-connector-cassandra] via GitHub
• 2026/10/21 [jira] [Updated] (FLINK-41070) Cassandra connector CI fails downloading the Flink 1.19.0 binary ASF GitHub Bot (Jira)
• 2026/10/21 Re: [PR] [BP-2.3][FLINK-34427][tests] Wait for slot manager close() in runTest [flink] via GitHub
• 2026/10/21 [jira] [Resolved] (FLINK-34427) FineGrainedSlotManagerTest fails fatally (exit code 239) Martijn Visser (Jira)
• 2026/10/21 [jira] [Comment Edited] (FLINK-34427) FineGrainedSlotManagerTest fails fatally (exit code 239) Martijn Visser (Jira)
• 2026/10/21 Re: [PR] [BP-1.20][FLINK-34427][tests] Wait for slot manager close() in runTest [flink] via GitHub
• 2026/10/21 Re: [PR] [BP-2.2][FLINK-34427][tests] Wait for slot manager close() in runTest [flink] via GitHub
• 2026/10/21 [jira] [Commented] (FLINK-40917) Deeply nested VARIANT values overflow the stack in toJson(), CAST to STRING and the variant builder Mika Naylor (Jira)
• 2026/10/21 [jira] [Commented] (FLINK-40132) MixedKubernetesServerExtension teardown flaky with RejectedExecutionException from Fabric8 Vert.x mock server shutdown Mika Naylor (Jira)
• 2026/10/21 Re: [PR] [BP-1.20][FLINK-38574][checkpoint] Avoid reusing re-uploaded sst files when checkpoint notification is delayed [flink] via GitHub
• 2026/10/21 [jira] [Commented] (FLINK-40655) ExecutionVertexTest.testResetForNewExecutionReleasesPartitions is unstable Mika Naylor (Jira)
• 2026/10/21 [jira] [Updated] (FLINK-40663) WindowDistinctAggregateStressITCase.testCumulateWindowRollupUnderBackpressure times out after 600s Martijn Visser (Jira)
• 2026/10/21 [jira] [Assigned] (FLINK-40655) ExecutionVertexTest.testResetForNewExecutionReleasesPartitions is unstable Mika Naylor (Jira)
• 2026/10/21 [jira] [Assigned] (FLINK-34224) ChangelogStorageMetricsTest.testAttemptsPerUpload(ChangelogStorageMetricsTest timed out Mika Naylor (Jira)
• 2026/10/21 [jira] [Resolved] (FLINK-33484) Flink Kafka Connector Offset Lag Issue with Transactional Data and Read Committed Isolation Level Martijn Visser (Jira)
• 2026/10/21 [jira] [Updated] (FLINK-41073) Checkpoint acknowledgement that fails shared state registration is dropped and the checkpoint waits for its timeout Martijn Visser (Jira)
• 2026/10/21 [jira] [Commented] (FLINK-40964) Streaming Top-N over an updating ROW_NUMBER input never retracts a replaced row (outer Rank uses AppendFastStrategy) Mika Naylor (Jira)
• 2026/10/21 [jira] [Updated] (FLINK-40663) WindowDistinctAggregateStressITCase.testCumulateWindowRollupUnderBackpressure times out after 600s Martijn Visser (Jira)
• 2026/10/21 Re: [I] [Bug][runtime] An input that triggers no Actions can strand the next input queued for the same key [flink-agents] via GitHub
• 2026/10/21 [jira] [Commented] (FLINK-40964) Streaming Top-N over an updating ROW_NUMBER input never retracts a replaced row (outer Rank uses AppendFastStrategy) sepuri sai krishna (Jira)
• 2026/10/21 [jira] [Commented] (FLINK-35499) EventTimeWindowCheckpointingITCase times out due to Checkpoint expired before completing Martijn Visser (Jira)
• 2026/10/21 [jira] [Commented] (FLINK-40663) WindowDistinctAggregateStressITCase.testCumulateWindowRollupUnderBackpressure times out after 600s Martijn Visser (Jira)
• 2026/10/21 [jira] [Created] (FLINK-41073) Checkpoint acknowledgement that fails shared state registration is dropped and the checkpoint waits for its timeout Martijn Visser (Jira)
• 2026/10/21 [jira] [Commented] (FLINK-38574) Avoid reusing re-uploaded sst files when checkpoint notification is delayed Martijn Visser (Jira)
• 2026/10/21 Re: [PR] [FLINK-40919][table-planner] Do not reduce AVG on TINYINT, SMALLINT and INT to SUM / COUNT [flink] via GitHub
• 2026/10/21 [PR] [BP-1.20][FLINK-38574][checkpoint] Avoid reusing re-uploaded sst files when checkpoint notification is delayed [flink] via GitHub
• 2026/10/21 [jira] [Created] (FLINK-41072) Test configuration randomization on GitHub Actions always uses the same seed Martijn Visser (Jira)
• 2026/10/21 [jira] [Created] (FLINK-41071) Upgrade Testcontainers to 1.21.4 in the Cassandra connector to support Docker 29 Martijn Visser (Jira)
• 2026/10/21 [jira] [Reopened] (FLINK-38485) Cassandra connector weekly CI is failing with NoClassDefFound Martijn Visser (Jira)
• 2026/10/21 [jira] [Created] (FLINK-41070) Cassandra connector CI fails downloading the Flink 1.19.0 binary Martijn Visser (Jira)
• 2026/10/21 [jira] [Commented] (FLINK-40065) flink-connector-aws: update flink-connector-parent to 2.0.0 and flink.version to 2.1. Purushottam Sinha (Jira)
• 2026/10/21 Re: [PR] [FLINK-36902][core] Keep process exit working on JDK 24+ where the Security Manager is disabled [flink] via GitHub
• 2026/10/21 [jira] [Commented] (FLINK-34224) ChangelogStorageMetricsTest.testAttemptsPerUpload(ChangelogStorageMetricsTest timed out Mika Naylor (Jira)
• 2026/10/21 Re: [I] [Doc][Umbrella] Walk through documentation and validate documented functionality for 0.4 [flink-agents] via GitHub
• 2026/10/21 Re: [PR] [FLINK-40664][tests] Isolate MDC logging test clusters [flink] via GitHub
• 2026/10/21 Re: [PR] [FLINK-41057][iceberg] Fix append-only update and delete handling [flink-cdc] via GitHub
• 2026/10/21 [jira] [Commented] (FLINK-40655) ExecutionVertexTest.testResetForNewExecutionReleasesPartitions is unstable sepuri sai krishna (Jira)
• 2026/10/21 Re: [PR] [FLINK-40919][table-planner] Do not reduce AVG on TINYINT, SMALLINT and INT to SUM / COUNT [flink] via GitHub
• 2026/10/21 [jira] [Created] (FLINK-41069) Add support for Flink 2.2 to flink-connector-aws Muhammad (Jira)
• 2026/10/21 Re: [I] [Doc] Walkthrough findings for Setup, multi-Agent Quickstart and Flink integration [flink-agents] via GitHub
• 2026/10/21 [jira] [Updated] (FLINK-40968) Accept map() as op_mapping in Table API toChangelog() and fromChangelog() Gustavo de Morais (Jira)
• 2026/10/21 [jira] [Created] (FLINK-41063) DataStream large-record sorting unnecessarily falls back to Kryo for payload serialization Jira
• 2026/10/21 [jira] [Commented] (FLINK-40077) CommonExecSinkITCase.testNullEnforcer fails intermittently: lost NoMoreSplitsEvent failover masks the NOT NULL enforcer cause Martijn Visser (Jira)
• 2026/10/21 [PR] [BP-1.20][FLINK-40904][FLINK-40780][runtime] Detect FORWARD parallelism mismatch correctly and make the downgrade configurable [flink] via GitHub
• 2026/10/21 [jira] [Created] (FLINK-41066) MultiJoin produces wrong results when an upsert input replaces a record without UPDATE_BEFORE Gustavo de Morais (Jira)
• 2026/10/21 Re: [PR] [FLINK-41034][table] Don't store rows whose join key can never match in streaming joins [flink] via GitHub
• 2026/10/21 [PR] [BP-1.20][FLINK-41053][test] Backport MAX_RETAINED_CHECKPOINTS fix to UnalignedCheckpointRescaleWithMixedExchangesITCase [flink] via GitHub
• 2026/10/21 [jira] [Assigned] (FLINK-40964) Streaming Top-N over an updating ROW_NUMBER input never retracts a replaced row (outer Rank uses AppendFastStrategy) Mika Naylor (Jira)
• 2026/10/21 [jira] [Created] (FLINK-41065) Improve TypeInferenceUtil for built-in PTFs Timo Walther (Jira)
• 2026/10/21 Re: [I] [Tech Debt][api] Chat model setups handle a blank model differently across providers and languages [flink-agents] via GitHub
• 2026/10/21 [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/21 [jira] [Commented] (FLINK-41053) UnalignedCheckpointRescaleWithMixedExchangesITCase.testRescaleFromUnalignedCheckpoint cannot find chk-1 on restore on release-1.20 Purushottam Sinha (Jira)
• 2026/10/21 [jira] [Created] (FLINK-41067) Window and interval joins store rows whose join key can never match Rion Williams (Jira)
• 2026/10/21 Re: [PR] [FLINK-40192][python] Add as-of join support to DataFrame API [flink] via GitHub
• 2026/10/21 Re: [PR] [FLINK-40192][python] Add as-of join support to DataFrame API [flink] via GitHub
• 2026/10/21 [jira] [Commented] (FLINK-41069) Add support for Flink 2.2 to flink-connector-aws Muhammad (Jira)
• 2026/10/21 [jira] [Created] (FLINK-41068) LATERAL SNAPSHOT join stores build-side rows whose join key can never match Rion Williams (Jira)
• 2026/10/21 [PR] [BP-2.2][FLINK-40904][FLINK-40780][runtime] Detect FORWARD parallelism mismatch correctly and make the downgrade configurable [flink] via GitHub
• 2026/10/21 [jira] [Comment Edited] (FLINK-34625) TTL doesn't seem to work in pyflink Dian Fu (Jira)
• 2026/10/21 Re: [PR] [BP-2.2][FLINK-40904][FLINK-40780][runtime] Detect FORWARD parallelism mismatch correctly and make the downgrade configurable [flink] via GitHub
• 2026/10/21 Re: [D] Community Sync - 2026 [flink-agents] via GitHub
• 2026/10/21 [jira] [Resolved] (FLINK-40968) Accept map() as op_mapping in Table API toChangelog() and fromChangelog() Gustavo de Morais (Jira)
• 2026/10/21 Re: [PR] [BP-1.20][FLINK-40904][FLINK-40780][runtime] Detect FORWARD parallelism mismatch correctly and make the downgrade configurable [flink] via GitHub
• 2026/10/21 [PR] [BP-2.3][FLINK-40904][FLINK-40780][runtime] Detect FORWARD parallelism mismatch correctly and make the downgrade configurable [flink] via GitHub
• 2026/10/21 [PR] [FLINK-36902][core] Keep process exit working on JDK 24+ where the Security Manager is disabled [flink] via GitHub
• 2026/10/21 Re: [PR] [FLINK-33484][Connectors/Kafka] Fix offsets committed to Kafka [flink-connector-kafka] via GitHub
• 2026/10/21 Re: [PR] [FLINK-33484][Connectors/Kafka] Fix offsets committed to Kafka [flink-connector-kafka] via GitHub
• 2026/10/21 [I] [Bug][runtime] Continuation execution ignores max-in-flight-input-records on JDK 21 [flink-agents] via GitHub
• 2026/10/21 [jira] [Assigned] (FLINK-40663) WindowDistinctAggregateStressITCase.testCumulateWindowRollupUnderBackpressure times out after 600s Martijn Visser (Jira)
• 2026/10/21 [jira] [Resolved] (FLINK-40567) HistoryServerArchiveFetcherTest.testLazyFetchArchiveProactively is flaky on @TempDir cleanup Mika Naylor (Jira)
• 2026/10/21 [jira] [Commented] (FLINK-33186) CheckpointAfterAllTasksFinishedITCase.testRestoreAfterSomeTasksFinished fails on AZP Martijn Visser (Jira)
• 2026/10/21 [jira] [Commented] (FLINK-38770) pipeline.jobvertex-parallelism-overrides ignored for StreamGraph in Application Mode Mika Naylor (Jira)
• 2026/10/21 Re: [PR] [FLINK-41063][runtime] Extract only sorting fields for large byte-key records [flink] via GitHub
• 2026/10/21 Re: [PR] [FLINK-33186][tests] Re-disable periodic checkpoints in the restored job of CheckpointAfterAllTasksFinishedITCase [flink] via GitHub

• Earlier messages
• Later messages