issues  

Messages by Date

• 2026/09/28 [PR] [runtime] Replay a durable call that returned null instead of throwing [flink-agents] via GitHub
• 2026/09/28 Re: [I] [Bug][runtime] Replaying a durable call that returned null throws NullPointerException [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 Re: [PR] [FLINK-40809][table] Do no count an updated record as a new match in StreamingJoinOperator [flink] via GitHub
• 2026/09/28 [jira] [Commented] (FLINK-40568) ProcessTableFunctionSemanticTests[process-updating-multi-input] is flaky on master Purushottam Sinha (Jira)
• 2026/09/28 [jira] [Updated] (FLINK-40830) Reuse jdk getBytes for StringUtf8Utils ASF GitHub Bot (Jira)
• 2026/09/28 [jira] [Updated] (FLINK-38534) Fix flaky LocalRecoveryTest by waiting for tasks to reach RUNNING state Martijn Visser (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-40109) YARNSessionFIFOSecuredITCase.testDetachedMode is flaky: Kerberos keytab check runs before the YARN application is killed Martijn Visser (Jira)
• 2026/09/28 Re: [PR] [FLINK-40829][python] Allow assign uid for Timestamp operators [flink] via GitHub
• 2026/09/28 [jira] [Updated] (FLINK-40829) operators hidden by `assign_timestamps_and_watermarks` get no uid, breaking `pipeline.auto-generate-uids: false` ASF GitHub Bot (Jira)
• 2026/09/28 [PR] [FLINK-40829][python] Allow assign uid for Timestamp operators [flink] via GitHub
• 2026/09/28 [jira] [Updated] (FLINK-40825) Support casting primitive types to VARIANT ASF GitHub Bot (Jira)
• 2026/09/28 [PR] [FLINK-40825][table] Support casting primitive types to VARIANT [flink] via GitHub
• 2026/09/28 [jira] [Updated] (FLINK-40828) Make VARIANT toString() and result printing never fail ASF GitHub Bot (Jira)
• 2026/09/28 Re: [PR] [integration][observability] Add OpenTelemetry GenAI exporter for Agent Traces (Phase 1) [flink-agents] via GitHub
• 2026/09/28 [jira] [Updated] (FLINK-39330) FileSourceTextLinesITCase.testBoundedTextFileSourceWithJobManagerFailove fails Martijn Visser (Jira)
• 2026/09/28 [jira] [Closed] (FLINK-36548) ChangelogDelegateEmbeddedRocksDBStateBackendTest crashed due to exit code: 134 Martijn Visser (Jira)
• 2026/09/28 [PR] [FLINK-40828][core][table] Make VARIANT toString() and result printing never fail [flink] via GitHub
• 2026/09/28 [jira] [Updated] (FLINK-38534) Fix flaky LocalRecoveryTest by waiting for tasks to reach RUNNING state Martijn Visser (Jira)
• 2026/09/28 Re: [I] [Tech Debt][API][Event] Restore built-in event types at cross-language boundaries [flink-agents] via GitHub
• 2026/09/28 [jira] [Updated] (FLINK-40123) heck_logs_for_exceptions false-positives on S3A stream_write_exceptions counter, flaking test_kubernetes_materialized_table.sh Martijn Visser (Jira)
• 2026/09/28 Re: [PR] [FLINK-40828][core][table] Make VARIANT toString() and result printing never fail [flink] via GitHub
• 2026/09/28 Re: [PR] [integration][observability] Add OpenTelemetry GenAI exporter for Agent Traces (Phase 1) [flink-agents] via GitHub
• 2026/09/28 [jira] [Updated] (FLINK-33186) CheckpointAfterAllTasksFinishedITCase.testRestoreAfterSomeTasksFinished fails on AZP Martijn Visser (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-40663) WindowDistinctAggregateStressITCase.testCumulateWindowRollupUnderBackpressure times out after 600s Martijn Visser (Jira)
• 2026/09/28 [jira] [Updated] (FLINK-38536) FinalizeOnMasterTest failed in test_cron_hadoop313 core Martijn Visser (Jira)
• 2026/09/28 [jira] [Updated] (FLINK-38536) FinalizeOnMasterTest failed in test_cron_hadoop313 core Martijn Visser (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-32523) NotifyCheckpointAbortedITCase.testNotifyCheckpointAborted fails with timeout on AZP Martijn Visser (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-40123) heck_logs_for_exceptions false-positives on S3A stream_write_exceptions counter, flaking test_kubernetes_materialized_table.sh Martijn Visser (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-38506) SideOutputITCase.testWatermarkForwarding failed in test_cron_adaptive_scheduler tests Martijn Visser (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-33186) CheckpointAfterAllTasksFinishedITCase.testRestoreAfterSomeTasksFinished fails on AZP Martijn Visser (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-39107) OpenTelemetryEventReporterITCase fails with ContainerLaunch Container startup failed for image Martijn Visser (Jira)
• 2026/09/28 [jira] [Updated] (FLINK-40568) ProcessTableFunctionSemanticTests[process-updating-multi-input] is flaky on master Martijn Visser (Jira)
• 2026/09/28 [jira] [Updated] (FLINK-34427) FineGrainedSlotManagerTest fails fatally (exit code 239) Martijn Visser (Jira)
• 2026/09/28 [jira] [Closed] (FLINK-37948) ChangelogDelegateEmbeddedRocksDBStateBackendTest causes JVM crash in azure ci pipeline Martijn Visser (Jira)
• 2026/09/28 [jira] [Updated] (FLINK-32523) NotifyCheckpointAbortedITCase.testNotifyCheckpointAborted fails with timeout on AZP Martijn Visser (Jira)
• 2026/09/28 [jira] [Updated] (FLINK-40109) YARNSessionFIFOSecuredITCase.testDetachedMode is flaky: Kerberos keytab check runs before the YARN application is killed Martijn Visser (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-40132) MixedKubernetesServerExtension teardown flaky with RejectedExecutionException from Fabric8 Vert.x mock server shutdown Martijn Visser (Jira)
• 2026/09/28 [jira] [Updated] (FLINK-40791) OpenTelemetryMetricReporterITCase.testCounterDelta fails with expected 1234 but was 25 Martijn Visser (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-38727) Unstable test cases EventTimeWindowCheckpointingITCase.testPreAggregatedSlidingTimeWindow Martijn Visser (Jira)
• 2026/09/28 [jira] [Updated] (FLINK-34513) GroupAggregateRestoreTest.testRestore fails Martijn Visser (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-34513) GroupAggregateRestoreTest.testRestore fails Martijn Visser (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-34427) FineGrainedSlotManagerTest fails fatally (exit code 239) Martijn Visser (Jira)
• 2026/09/28 [jira] [Updated] (FLINK-36297) SIGSEGV caused CI failure Martijn Visser (Jira)
• 2026/09/28 [jira] [Updated] (FLINK-40663) WindowDistinctAggregateStressITCase.testCumulateWindowRollupUnderBackpressure times out after 600s Martijn Visser (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-36297) SIGSEGV caused CI failure Martijn Visser (Jira)
• 2026/09/28 Re: [I] [Tech Debt][API][Flink Integration] Simplify Agent output materialization to DataStream and Table [flink-agents] via GitHub
• 2026/09/28 [jira] [Reopened] (FLINK-36299) AdaptiveSchedulerTest.testStatusMetrics times out Martijn Visser (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-35335) StateCheckpointedITCase failed fatally with 127 exit code Martijn Visser (Jira)
• 2026/09/28 [jira] [Updated] (FLINK-35335) StateCheckpointedITCase failed fatally with 127 exit code Martijn Visser (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-39214) Support TIME type precision beyond milliseconds (precision > 3) suntectec (Jira)
• 2026/09/28 [jira] [Created] (FLINK-40828) Make VARIANT toString() and result printing never fail Ramin Gharib (Jira)
• 2026/09/28 [jira] [Updated] (FLINK-37501) Incorrect url for jobmanager log on history server Dmitriy Linevich (Jira)
• 2026/09/28 Re: [PR] [FLINK-40595][s3] Preserve multipart uploads during recoverable stream disposal [flink] via GitHub
• 2026/09/28 [jira] [Updated] (FLINK-37501) Incorrect url for jobmanager log on history server Dmitriy Linevich (Jira)
• 2026/09/28 [jira] [Commented] (FLINK-40470) Savepoint redeploy loops forever when the deployment attempt fails Robert Metzger (Jira)
• 2026/09/28 [jira] [Updated] (FLINK-37501) Incorrect url for jobmanager log on history server Dmitriy Linevich (Jira)
• 2026/09/28 [jira] [Updated] (FLINK-39340) Transform binary multi join back to regular join Dmitriy Linevich (Jira)
• 2026/09/28 [jira] [Updated] (FLINK-39285) Consider the result of filter pushdown rules in the MultiJoin rule Dmitriy Linevich (Jira)
• 2026/09/28 [jira] [Updated] (FLINK-39340) Transform binary multi join back to regular join Dmitriy Linevich (Jira)
• 2026/09/28 [jira] [Assigned] (FLINK-40810) FlinkSessionJob deletion leaves the job running when a transient Job Not Found error was never cleared Robert Metzger (Jira)
• 2026/09/28 Re: [PR] [FLINK-40602][runtime] JobManager silently omits running jobs whose JobMaster fails or times out on GET /jobs/overview [flink] via GitHub
• 2026/09/28 Re: [PR] [FLINK-39789] AvroSchemaConverter updates for local-timestamp-* and timestamp-nanos logical types [flink] via GitHub
• 2026/09/28 Re: [PR] [FLINK-40602][runtime] JobManager silently omits running jobs whose JobMaster fails or times out on GET /jobs/overview [flink] via GitHub
• 2026/09/28 Re: [PR] [FLINK-40602][runtime] JobManager silently omits running jobs whose JobMaster fails or times out on GET /jobs/overview [flink] via GitHub
• 2026/09/28 [jira] [Resolved] (FLINK-40514) [Docs] Doris pipeline connector option table does not match implementation Xiqian Yu (Jira)
• 2026/09/28 Re: [PR] [runtime][java] Replay pending Kafka action state on recovery [flink-agents] via GitHub
• 2026/09/28 Re: [PR] [FLINK-39789] AvroSchemaConverter updates for local-timestamp-* and timestamp-nanos logical types [flink] via GitHub
• 2026/09/27 Re: [PR] [integrations][java] Add PostgreSQL pgvector vector store [flink-agents] via GitHub
• 2026/09/27 [jira] [Assigned] (FLINK-40470) Savepoint redeploy loops forever when the deployment attempt fails Robert Metzger (Jira)
• 2026/09/27 Re: [PR] [api][java][python] Reject non-positive max_results in ContextRetrievalRequestEvent [flink-agents] via GitHub
• 2026/09/27 [jira] [Assigned] (FLINK-40693) FLOAT/DOUBLE IN and NOT IN disagree with equality for signed zero Sergey Nuyanzin (Jira)
• 2026/09/27 [jira] [Commented] (FLINK-40693) FLOAT/DOUBLE IN and NOT IN disagree with equality for signed zero Sergey Nuyanzin (Jira)
• 2026/09/27 [jira] [Resolved] (FLINK-40827) Bump jline to 3.30.17 Sergey Nuyanzin (Jira)
• 2026/09/27 [jira] [Commented] (FLINK-40827) Bump jline to 3.30.17 Sergey Nuyanzin (Jira)
• 2026/09/27 Re: [PR] [api][java] Include the memory type in MemoryRef equality and reject null fields [flink-agents] via GitHub
• 2026/09/27 Re: [PR] [FLINK-40827][table] Bump jline to 3.30.17 [flink] via GitHub
• 2026/09/27 Re: [I] [Bug][api][plan] ModelRouter builder and plan construction accept invalid candidate declarations [flink-agents] via GitHub
• 2026/09/27 Re: [PR] [api][plan][java] Validate router candidates and default model at declaration [flink-agents] via GitHub
• 2026/09/27 Re: [PR] [FLINK-40813][clients] Remove the deprecated configuration keys from the flink-clients module. [flink] via GitHub
• 2026/09/27 [jira] [Resolved] (FLINK-40813) Remove the deprecated configuration keys from the flink-clients module. Yuepeng Pan (Jira)
• 2026/09/27 [jira] [Updated] (FLINK-40813) Remove the deprecated configuration keys from the flink-clients module. Yuepeng Pan (Jira)
• 2026/09/27 Re: [PR] [FLINK-40813][clients] Remove the deprecated configuration keys from the flink-clients module. [flink] via GitHub
• 2026/09/27 Re: [PR] [api][java][python] Align multimodal message contracts and safe logging [flink-agents] via GitHub
• 2026/09/27 Re: [PR] [FLINK-40693][table] Align floating-point IN predicates with equality for signed zero [flink] via GitHub
• 2026/09/27 Re: [PR] [FLINK-40595][s3] Preserve multipart uploads during recoverable stream disposal [flink] via GitHub
• 2026/09/27 [PR] [integration][java] Forward assistant tool calls in the Ollama chat history [flink-agents] via GitHub
• 2026/09/27 [PR] [FLINK-40396][connector-base] Create split readers on the split fetcher thread [flink] via GitHub
• 2026/09/27 [PR] [integration][python] Pass DashScope tool call ids through to Tongyi tool results [flink-agents] via GitHub
• 2026/09/27 [I] [Bug] Java Ollama connection drops assistant tool calls from the chat history [flink-agents] via GitHub
• 2026/09/27 Re: [PR] [api][java][python] Align multimodal message contracts and safe logging [flink-agents] via GitHub
• 2026/09/27 [PR] [integration][java][python] Send multimodal user messages through OpenAI Chat Completions [flink-agents] via GitHub
• 2026/09/27 [PR] [api][java][python] Align multimodal message contracts and safe logging [flink-agents] via GitHub
• 2026/09/27 Re: [I] [Feature] Multimodal content blocks in ChatMessage [flink-agents] via GitHub
• 2026/09/27 Re: [PR] [integration][observability] Add OpenTelemetry GenAI exporter for Agent Traces (Phase 1) [flink-agents] via GitHub
• 2026/09/27 Re: [PR] [FLINK-36581][cli] Allow passing Flink configuration by yaml job file [flink-cdc] via GitHub
• 2026/09/27 Re: [PR] [api] Introduce multimodal content blocks [flink-agents] via GitHub
• 2026/09/27 Re: [PR] [FLINK-36581][cli] Allow passing Flink configuration by yaml job file [flink-cdc] via GitHub
• 2026/09/27 Re: [PR] [hotfix][ci] Pull MinIO for Milvus tests from Bitnami's legacy image [flink-agents] via GitHub
• 2026/09/27 Re: [PR] [FLINK-39721] Support flink 1.18 compatibility for cdc runtime. [flink-cdc] via GitHub
• 2026/09/27 Re: [PR] [FLINK-39721] Support flink 1.18 compatibility for cdc runtime. [flink-cdc] via GitHub
• 2026/09/27 Re: [PR] [FLINK-40538][postgres] Skip WAL position search on idle publication … [flink-cdc] via GitHub
• 2026/09/27 [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/27 [jira] [Assigned] (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/27 [jira] [Comment Edited] (FLINK-8093) flink job fail because of kafka producer create fail of "javax.management.InstanceAlreadyExistsException" Seungki Kim (Jira)
• 2026/09/27 [jira] [Comment Edited] (FLINK-8093) flink job fail because of kafka producer create fail of "javax.management.InstanceAlreadyExistsException" Seungki Kim (Jira)
• 2026/09/27 Re: [PR] [FLINK-40751][state-processor-api] Use task io/memory manager in SavepointEnvironment [flink] via GitHub
• 2026/09/27 Re: [PR] [FLINK-39354] Fix case-insensitive existing-column lookup in SchemaUtils.applyAddColumnEvent [flink-cdc] via GitHub
• 2026/09/27 Re: [PR] [FLINK-38959][pipeline-connector][postgres]Added support for schema change in the postgres pipeline connector [flink-cdc] via GitHub
• 2026/09/27 Re: [PR] [FLINK-38959][pipeline-connector][postgres]Added support for schema change in the postgres pipeline connector [flink-cdc] via GitHub
• 2026/09/27 Re: [PR] [FLINK-39354] Fix case-insensitive existing-column lookup in SchemaUtils.applyAddColumnEvent [flink-cdc] via GitHub
• 2026/09/27 Re: [PR] [FLINK-40670][tests] Make Semantic tests tolerant to concurrent runs [flink] via GitHub
• 2026/09/27 [jira] [Updated] (FLINK-40670) MultiJoinSemanticTests[four-way-mixed-join-multi-key-types-shuffled] loses a row on release-2.3 ASF GitHub Bot (Jira)
• 2026/09/27 [PR] [FLINK-40670][tests] Make Semantic tests tolerant to concurrent runs [flink] via GitHub
• 2026/09/27 [jira] [Assigned] (FLINK-40670) MultiJoinSemanticTests[four-way-mixed-join-multi-key-types-shuffled] loses a row on release-2.3 Sergey Nuyanzin (Jira)
• 2026/09/27 Re: [PR] [FLINK-40678][table] Include the scan's hints in the lookup join digest [flink] via GitHub
• 2026/09/27 [jira] [Updated] (FLINK-40678) Lookup join digest ignores table OPTIONS hints ASF GitHub Bot (Jira)
• 2026/09/27 [PR] [FLINK-40678][table] Include the scan's hints in the lookup join digest [flink] via GitHub
• 2026/09/27 [jira] [Resolved] (FLINK-40803) "Build documentation" fails with startup_failure because the burnett01/rsync-deployments 8.0.5 pin expired Martijn Visser (Jira)
• 2026/09/27 Re: [PR] [FLINK-40803][ci] Deploy docs with rsync instead of rsync-deployments [flink] via GitHub
• 2026/09/27 [jira] [Created] (FLINK-40827) Bump jline to 3.30.17 Sergey Nuyanzin (Jira)
• 2026/09/27 Re: [PR] [FLINK-40827][table] Bump jline to 3.30.17 [flink] via GitHub
• 2026/09/27 [jira] [Updated] (FLINK-40827) Bump jline to 3.30.17 ASF GitHub Bot (Jira)
• 2026/09/27 [PR] [FLINK-40827][table] Bump jline to 3.30.17 [flink] via GitHub
• 2026/09/27 [jira] [Commented] (FLINK-38558) Checkpoint rescale and restore fails with RocksDB Heap timer Roman Khachatryan (Jira)
• 2026/09/27 Re: [PR] [FLINK-40693][table] Align floating-point IN predicates with equality for signed zero [flink] via GitHub
• 2026/09/27 Re: [PR] [FLINK-40693][table] Align floating-point IN predicates with equality for signed zero [flink] via GitHub
• 2026/09/27 [jira] [Commented] (FLINK-40822) Bump maven-compiler-plugin to 3.16.0 Sergey Nuyanzin (Jira)
• 2026/09/27 [jira] [Assigned] (FLINK-39380) Add support for test snapshotting/restoration to ProcessTableFunctionTestHarness Mika Naylor (Jira)
• 2026/09/27 [jira] [Updated] (FLINK-40826) Support casting constructed types to VARIANT Ramin Gharib (Jira)
• 2026/09/27 Re: [PR] [FLINK-32806][runtime] Support eviction of clean job result entries in EmbeddedJobResultStore [flink] via GitHub
• 2026/09/27 [jira] [Commented] (FLINK-32806) EmbeddedJobResultStore keeps the non-dirty job entries forever william (Jira)
• 2026/09/27 [PR] [FLINK-32806][runtime] Support eviction of clean job result entries in EmbeddedJobResultStore [flink] via GitHub
• 2026/09/27 [jira] [Commented] (FLINK-32806) EmbeddedJobResultStore keeps the non-dirty job entries forever william (Jira)
• 2026/09/27 [jira] [Created] (FLINK-40826) Support casting constructed types to VARIANT Ramin Gharib (Jira)
• 2026/09/27 [jira] [Commented] (FLINK-39380) Add support for test snapshotting/restoration to ProcessTableFunctionTestHarness Mika Naylor (Jira)
• 2026/09/27 [jira] [Created] (FLINK-40825) Support casting primitive types to VARIANT Ramin Gharib (Jira)
• 2026/09/27 [jira] [Updated] (FLINK-40826) Support casting constructed types to VARIANT Ramin Gharib (Jira)
• 2026/09/27 [jira] [Updated] (FLINK-40824) Support casting to VARIANT Ramin Gharib (Jira)
• 2026/09/27 [jira] [Created] (FLINK-40824) Support casting to VARIANT Ramin Gharib (Jira)
• 2026/09/27 Re: [PR] [FLINK-40822][bulid] Bump maven-compiler-plugin to 3.16.0 [flink] via GitHub
• 2026/09/27 [jira] [Resolved] (FLINK-40822) Bump maven-compiler-plugin to 3.16.0 Sergey Nuyanzin (Jira)
• 2026/09/27 Re: [PR] [FLINK-40793][tests] Fix unstable DefaultSchedulerTest [flink] via GitHub
• 2026/09/27 [jira] [Commented] (FLINK-39380) Add support for test snapshotting/restoration to ProcessTableFunctionTestHarness sepuri sai krishna (Jira)
• 2026/09/27 Re: [PR] [FLINK-40693][table] Align floating-point IN predicates with equality for signed zero [flink] via GitHub
• 2026/09/27 Re: [PR] [FLINK-40693][table] Align floating-point IN predicates with equality for signed zero [flink] via GitHub
• 2026/09/27 Re: [PR] Kubernetes Operator 1.12.1 [flink-web] via GitHub
• 2026/09/27 Re: [PR] [FLINK-40419][python] Add regular join support to DataFrame API [flink] via GitHub
• 2026/09/27 Re: [PR] [hotfix][core] Update the default duration value setting coding on 'taskmanager.registration.timeout'. [flink] via GitHub
• 2026/09/27 Re: [PR] [FLINK-40354][state/forst] Configure the TTL compaction filter for State V2 states [flink] via GitHub
• 2026/09/27 Re: [PR] [FLINK-40644][state/forst] Close the remote stream when a CachedDataInputStream is closed [flink] via GitHub
• 2026/09/27 Re: [PR] [FLINK-40813][clients] Remove the deprecated configuration keys from the flink-clients module. [flink] via GitHub
• 2026/09/27 Re: [PR] [hotfix][core] Update the default duration value setting coding on 'taskmanager.registration.timeout'. [flink] via GitHub
• 2026/09/27 [jira] [Assigned] (FLINK-40812) [Backport][1.20] Backport FLINK-38558 to release-1.20 Roman Khachatryan (Jira)
• 2026/09/27 Re: [PR] [FLINK-40645][state/forst] Unregister closed streams from FileCacheEntry#openedStreams [flink] via GitHub
• 2026/09/27 Re: [PR] [FLINK-40681][table] Reproducer: streaming outer join drops the null-padded row after an inner-side update followed by delete [flink] via GitHub
• 2026/09/26 [jira] [Updated] (FLINK-39049) Introduce built-in functions `VARIANT_GET` and `TRY_VARIANT_GET ` to extract values from a variant Jinkun Liu (Jira)
• 2026/09/26 [jira] [Updated] (FLINK-39049) Introduce built-in functions `VARIANT_GET` and `TRY_VARIANT_GET ` to extract values from a variant Jinkun Liu (Jira)
• 2026/09/26 [jira] [Updated] (FLINK-39049) Introduce built-in functions `VARIANT_GET` and `TRY_VARIANT_GET ` to extract values from a variant Jinkun Liu (Jira)
• 2026/09/26 Re: [PR] [FLINK-39875][table-gateway] Restore thread interrupt status in ResultStore [flink] via GitHub
• 2026/09/26 [jira] [Updated] (FLINK-39049) Introduce built-in functions `VARIANT_GET` and `TRY_VARIANT_GET ` to extract values from a variant Jinkun Liu (Jira)
• 2026/09/26 Re: [PR] [FLINK-38961][metrics] Display process metrics (CPU, Memory, I/O) on TaskManager Web UI [flink] via GitHub
• 2026/09/26 Re: [PR] [FLINK-40793][tests] Fix unstable DefaultSchedulerTest [flink] via GitHub
• 2026/09/26 [jira] [Commented] (FLINK-39380) Add support for test snapshotting/restoration to ProcessTableFunctionTestHarness sepuri sai krishna (Jira)
• 2026/09/26 [jira] [Commented] (FLINK-40823) State Processor API docs do not mention that a checkpoint of a running job can be deleted while it is being read sepuri sai krishna (Jira)
• 2026/09/26 [jira] [Created] (FLINK-40823) State Processor API docs do not mention that a checkpoint of a running job can be deleted while it is being read sepuri sai krishna (Jira)
• 2026/09/26 Re: [PR] [FLINK-40425][python][table] Support OVER windows in DataFrame API [flink] via GitHub
• 2026/09/26 Re: [PR] [FLINK-40425][python][table] Support OVER windows in DataFrame API [flink] via GitHub
• 2026/09/26 [jira] [Updated] (FLINK-40425) Add OVER window aggregation support to DataFrame API ASF GitHub Bot (Jira)
• 2026/09/26 [PR] [FLINK-40425][python][table] Support OVER windows in DataFrame API [flink] via GitHub
• 2026/09/26 Re: [PR] [hotfix][core] Update the default duration value setting coding on 'taskmanager.registration.timeout'. [flink] via GitHub
• 2026/09/26 Re: [PR] [FLINK-38262][table] describe connection operation [flink] via GitHub
• 2026/09/26 Re: [PR] [FLINK-37288] Add Google Cloud Spanner dialect and catalog [flink-connector-jdbc] via GitHub
• 2026/09/26 [jira] [Commented] (FLINK-8093) flink job fail because of kafka producer create fail of "javax.management.InstanceAlreadyExistsException" Seungki Kim (Jira)
• 2026/09/26 [jira] [Commented] (FLINK-31762) Subscribe to multiple Kafka topics may cause partition assignment skew Seungki Kim (Jira)
• 2026/09/26 Re: [PR] [hotfix][flink-model-triton] Replaced the final resource closing with try with resource [flink] via GitHub
• 2026/09/26 Re: [PR] [hotfix][core] Update the default duration value setting coding on 'taskmanager.registration.timeout'. [flink] via GitHub
• 2026/09/26 Re: [PR] [hotfix][flink-model-triton] Replaced the final resource closing with try with resource [flink] via GitHub
• 2026/09/26 Re: [PR] [FLINK-40655][runtime] Fix flaky partition release test [flink] via GitHub
• 2026/09/26 Re: [PR] [FLINK-39749][mysql-cdc] Support configurable string chunk key comparison mode to align with MySQL collation [flink-cdc] via GitHub
• 2026/09/26 Re: [PR] [hotfix][ci] Skip CI on certain paths [flink-connector-kafka] via GitHub
• 2026/09/26 Re: [PR] [FLINK-40822][bulid] Bump maven-compiler-plugin to 3.16.0 [flink] via GitHub
• 2026/09/26 [PR] [FLINK-40822][bulid] Bump maven-compiler-plugin to 3.9.16 [flink] via GitHub
• 2026/09/26 [jira] [Updated] (FLINK-40822) Bump maven-compiler-plugin to 3.16.0 ASF GitHub Bot (Jira)
• 2026/09/26 [jira] [Created] (FLINK-40822) Bump maven-compiler-plugin to 3.16.0 Sergey Nuyanzin (Jira)
• 2026/09/26 [jira] [Updated] (FLINK-40822) Bump maven-compiler-plugin to 3.16.0 Sergey Nuyanzin (Jira)
• 2026/09/26 Re: [PR] [FLINK-34427][runtime] Pending tasks should be canceled if slot manager is closed [flink] via GitHub
• 2026/09/26 [jira] [Assigned] (FLINK-34427) FineGrainedSlotManagerTest fails fatally (exit code 239) Sergey Nuyanzin (Jira)
• 2026/09/26 [PR] [FLINK-34427][runtime] Pending tasks should be canceled if slot manager is closed [flink] via GitHub
• 2026/09/26 Re: [PR] [FLINK-40504][runtime] Re-activate idle FLIP-27 outputs when they resume [flink] via GitHub
• 2026/09/26 Re: [PR] [FLINK-40813][clients] Remove the deprecated configuration keys from the flink-clients module. [flink] via GitHub
• 2026/09/26 [PR] [FLINK-40813][clients] Remove the deprecated configuration keys from the flink-clients module. [flink] via GitHub
• 2026/09/26 [jira] [Updated] (FLINK-40813) Remove the deprecated configuration keys from the flink-clients module. ASF GitHub Bot (Jira)
• 2026/09/26 [jira] [Created] (FLINK-40821) Remove the fallback configuration keys from the flink-avro-confluent-registry module. Yuepeng Pan (Jira)
• 2026/09/26 [jira] [Created] (FLINK-40818) Remove the fallback configuration keys from the flink-core module. Yuepeng Pan (Jira)
• 2026/09/26 Re: [PR] [hotfix][flink-model-triton] Replaced the final resource closing with try with resource [flink] via GitHub
• 2026/09/26 [jira] [Created] (FLINK-40820) Remove the fallback configuration keys from the flink-s3-fs-base module. Yuepeng Pan (Jira)
• 2026/09/26 [jira] [Created] (FLINK-40819) Remove the fallback configuration keys from the flink-kubernetes module. Yuepeng Pan (Jira)
• 2026/09/26 [jira] [Created] (FLINK-40814) Remove the deprecated configuration keys from the flink-core module. Yuepeng Pan (Jira)
• 2026/09/26 [jira] [Created] (FLINK-40817) Remove the deprecated configuration keys from the flink-yarn module. Yuepeng Pan (Jira)

• Earlier messages
• Later messages