issues  

Messages by Date

• 2026/10/06 Re: [PR] [FLINK-40925][rest] `JobVertexBackPressureHandler` throws `NoSuchElementException` when execution attempts are pruned concurrently [flink] via GitHub
• 2026/10/06 Re: [PR] [FLINK-40925][rest] `JobVertexBackPressureHandler` throws `NoSuchElementException` when execution attempts are pruned concurrently [flink] via GitHub
• 2026/10/06 Re: [PR] [FLINK-40925][rest] `JobVertexBackPressureHandler` throws `NoSuchElementException` when execution attempts are pruned concurrently [flink] via GitHub
• 2026/10/06 Re: [PR] [FLINK-32806][runtime] Support eviction of clean job result entries in EmbeddedJobResultStore [flink] via GitHub
• 2026/10/06 Re: [PR] [FLINK-40277][connector-http] Add HTTP sink status-code handling and retries [flink-connector-http] via GitHub
• 2026/10/06 Re: [PR] [FLINK-40571][table-planner] Fix flaky process-stateful-multi-input-with-timeout PTF test [flink] via GitHub
• 2026/10/06 Re: [PR] [FLINK-40277][connector-http] Add HTTP sink status-code handling and retries [flink-connector-http] via GitHub
• 2026/10/06 Re: [PR] [FLINK-40277][connector-http] Add HTTP sink status-code handling and retries [flink-connector-http] via GitHub
• 2026/10/06 Re: [PR] [FLINK-40277][connector-http] Add HTTP sink status-code handling and retries [flink-connector-http] via GitHub
• 2026/10/06 [jira] [Commented] (FLINK-40655) ExecutionVertexTest.testResetForNewExecutionReleasesPartitions is unstable sepuri sai krishna (Jira)
• 2026/10/06 Re: [PR] [FLINK-40737][table] Keep non-time OVER data views inside the accumulator [flink] via GitHub
• 2026/10/06 Re: [PR] [FLINK-40298][table] Opt-in name-based state schema evolution for RowData [flink] via GitHub
• 2026/10/06 [jira] [Commented] (FLINK-40737) COLLECT over a non-time OVER window returns only the current row instead of the running window sepuri sai krishna (Jira)
• 2026/10/06 Re: [PR] [FLINK-40797][table-planner] Exclude NestedLoopJoin from CBO search space for equi-joins [flink] via GitHub
• 2026/10/06 Re: [PR] [FLINK-40737][table] Keep non-time OVER data views inside the accumulator [flink] via GitHub
• 2026/10/06 [PR] [FLINK-40737][table] Keep non-time OVER data views inside the accumulator [flink] via GitHub
• 2026/10/06 [jira] [Updated] (FLINK-40737) COLLECT over a non-time OVER window returns only the current row instead of the running window ASF GitHub Bot (Jira)
• 2026/10/06 [jira] [Updated] (FLINK-40737) COLLECT over a non-time OVER window returns only the current row instead of the running window sepuri sai krishna (Jira)
• 2026/10/06 Re: [PR] [FLINK-40571][table-planner] Fix flaky process-stateful-multi-input-with-timeout PTF test [flink] via GitHub
• 2026/10/06 [jira] [Commented] (FLINK-22599) Point to `client.timeout` in error messages where it is used for rpc timeout Amrit Sarkar (Jira)
• 2026/10/06 Re: [PR] [FLINK-40297][runtime] Route TTL-aware value migration through the migrate hook [flink] via GitHub
• 2026/10/06 Re: [PR] [FLINK-40046][runtime-web] Upgrade @antv/g2 to v5 [flink] via GitHub
• 2026/10/06 [jira] [Commented] (FLINK-40737) COLLECT over a non-time OVER window returns only the current row instead of the running window sepuri sai krishna (Jira)
• 2026/10/06 Re: [PR] [FLINK-40293][table] Add UDF metric config options and instrument sync scalar and table UDF calls [flink] via GitHub
• 2026/10/06 [jira] [Closed] (FLINK-40293) Add UDF metric config options and instrument sync scalar and table UDF calls Weiqing Yang (Jira)
• 2026/10/06 Re: [PR] [FLINK-40172][table-runtime] Support processing-time early fire on a row-time interval join [flink] via GitHub
• 2026/10/06 Re: [PR] [runtime][java][skills] Bound download and extraction size [flink-agents] via GitHub
• 2026/10/06 [jira] [Assigned] (FLINK-34673) SessionRelatedITCase#testTouchSession failure on GitHub Actions Martijn Visser (Jira)
• 2026/10/06 [jira] [Resolved] (FLINK-34673) SessionRelatedITCase#testTouchSession failure on GitHub Actions Martijn Visser (Jira)
• 2026/10/06 [jira] [Commented] (FLINK-39998) RocksDBStateDownloader loses parallel download failures, surfacing a misleading ClosedChannelException instead of the real root cause Amrit Sarkar (Jira)
• 2026/10/06 Re: [PR] [FLINK-34673][test] Fix SessionRelatedITCase#testTouchSession failure on GitHub Actions [flink] via GitHub
• 2026/10/06 [jira] (FLINK-39998) RocksDBStateDownloader loses parallel download failures, surfacing a misleading ClosedChannelException instead of the real root cause Amrit Sarkar (Jira)
• 2026/10/06 [jira] [Resolved] (FLINK-40644) ForSt file cache: CachedDataInputStream.close() does not close the remote (original) stream, leaking S3A connections until the pool is exhausted Zakelly Lan (Jira)
• 2026/10/06 [jira] [Commented] (FLINK-40644) ForSt file cache: CachedDataInputStream.close() does not close the remote (original) stream, leaking S3A connections until the pool is exhausted Zakelly Lan (Jira)
• 2026/10/06 Re: [PR] [FLINK-40644][state/forst] Close the remote stream when a CachedDataInputStream is closed [flink] via GitHub
• 2026/10/06 Re: [D] [Discussion] Context compaction for Flink Agents [flink-agents] via GitHub
• 2026/10/06 Re: [D] [Discussion] Context compaction for Flink Agents [flink-agents] via GitHub
• 2026/10/06 Re: [PR] [FLINK-40277][connector-http] Add HTTP sink status-code handling and retries [flink-connector-http] via GitHub
• 2026/10/06 Re: [PR] [FLINK-40277][connector-http] Add HTTP sink status-code handling and retries [flink-connector-http] via GitHub
• 2026/10/06 Re: [PR] [FLINK-40277][connector-http] Add HTTP sink status-code handling and retries [flink-connector-http] via GitHub
• 2026/10/06 Re: [PR] [FLINK-40277][connector-http] Add HTTP sink status-code handling and retries [flink-connector-http] via GitHub
• 2026/10/06 [D] [Discussion] Context compaction for Flink Agents [flink-agents] via GitHub
• 2026/10/06 [jira] [Resolved] (FLINK-40913) CheckpointSyncPhaseTimeoutITCase failures race Martijn Visser (Jira)
• 2026/10/06 Re: [PR] [FLINK-40913][tests] Use a single vertex job in testStuckSyncPhaseFailsJob to avoid failures race [flink] via GitHub
• 2026/10/06 Re: [PR] [FLINK-40910][table] Reject VARIANT where a query needs equality or ordering [flink] via GitHub
• 2026/10/06 Re: [PR] [FLINK-40571][table-planner] Fix flaky process-stateful-multi-input-with-timeout PTF test [flink] via GitHub
• 2026/10/06 [jira] [Commented] (FLINK-32212) Job restarting indefinitely after an IllegalStateException from BlobLibraryCacheManager Ricky Saltzer (Jira)
• 2026/10/06 [jira] [Updated] (FLINK-40913) CheckpointSyncPhaseTimeoutITCase failures race Martijn Visser (Jira)
• 2026/10/06 [jira] [Updated] (FLINK-40910) Reject VARIANT where SQL needs equality. Byte comparison gives wrong results in GROUP BY, DISTINCT, joins and = ASF GitHub Bot (Jira)
• 2026/10/06 [PR] [FLINK-40910][table] Reject VARIANT where a query needs equality or ordering [flink] via GitHub
• 2026/10/06 [jira] [Updated] (FLINK-40910) Reject VARIANT where SQL needs equality. Byte comparison gives wrong results in GROUP BY, DISTINCT, joins and = Ramin Gharib (Jira)
• 2026/10/06 Re: [PR] [FLINK-40046][runtime-web] Upgrade @antv/g2 to v5 [flink] via GitHub
• 2026/10/06 [jira] [Resolved] (FLINK-40200) Introduce sync phase timeout for TaskManagers locking up in org.rocksdb.Checkpoint.createCheckpoint Martijn Visser (Jira)
• 2026/10/06 Re: [PR] [FLINK-36146][connector-base] Fix SingleThreadFetcherManager race condition [flink] via GitHub
• 2026/10/06 [jira] [Resolved] (FLINK-36146) NoSuchElement exception from SingleThreadFetcherManager Martijn Visser (Jira)
• 2026/10/06 [jira] [Assigned] (FLINK-36146) NoSuchElement exception from SingleThreadFetcherManager Martijn Visser (Jira)
• 2026/10/06 Re: [PR] [BP-2.3][FLINK-36146][connector-base] Fix SingleThreadFetcherManager race condition [flink] via GitHub
• 2026/10/06 Re: [PR] [BP-2.2][FLINK-36146][connector-base] Fix SingleThreadFetcherManager race condition [flink] via GitHub
• 2026/10/06 Re: [PR] [BP-1.20][FLINK-36146][connector-base] Fix SingleThreadFetcherManager race condition [flink] via GitHub
• 2026/10/06 [jira] [Closed] (FLINK-40826) Support casting constructed types to VARIANT Timo Walther (Jira)
• 2026/10/06 [jira] [Closed] (FLINK-40911) Variant builder mishandles a nested variant and a value of exactly 16 MiB Timo Walther (Jira)
• 2026/10/06 [jira] [Commented] (FLINK-40856) Support zip-style multi-column explode in DataFrame API Bettle (Jira)
• 2026/10/06 Re: [PR] [FLINK-40826][table] Support casting ARRAY, MAP, ROW and STRUCTURED to VARIANT [flink] via GitHub
• 2026/10/06 Re: [PR] [FLINK-40885][table] Support LATERAL SNAPSHOT join in the Table API [flink] via GitHub
• 2026/10/06 Re: [PR] [FLINK-40885][table] Support LATERAL SNAPSHOT join in the Table API [flink] via GitHub
• 2026/10/06 Re: [PR] [FLINK-40925][rest] `JobVertexBackPressureHandler` throws `NoSuchElementException` when execution attempts are pruned concurrently [flink] via GitHub
• 2026/10/06 Re: [PR] [Backport][FLINK-39966][FLINK-40368][table] Backport Top-1 deduplication changelog fixes to 2.1 [flink] via GitHub
• 2026/10/06 Re: [PR] [FLINK-40920][table-planner] Fix ClassCastException when reducing a division by a constant expression [flink] via GitHub
• 2026/10/06 [jira] [Commented] (FLINK-40368) Deduplicate output should only be insert-only when ordered by time attribute Gustavo de Morais (Jira)
• 2026/10/06 [jira] [Created] (FLINK-40926) Projection push down records a ReadingMetadata ability without metadata keys Arvid Heise (Jira)
• 2026/10/06 Re: [PR] [FLINK-40645][state/forst] Unregister closed streams from FileCacheEntry#openedStreams [flink] via GitHub
• 2026/10/06 Re: [PR] [FLINK-40909][table-planner] Support filter push down for element access on ARRAY, MAP and VARIANT [flink] via GitHub
• 2026/10/06 Re: [PR] [FLINK-40735][table] Compare non-time OVER accumulators with a generated equaliser [flink] via GitHub
• 2026/10/06 [PR] [BP-1.20][FLINK-36146][connector-base] Fix SingleThreadFetcherManager race condition [flink] via GitHub
• 2026/10/06 Re: [PR] [hotfix] Notice change [flink-connector-http] via GitHub
• 2026/10/06 [jira] [Updated] (FLINK-40735) OVER window ordered by a non-time attribute fails for LAG and ARRAY_AGG when a row arrives out of order ASF GitHub Bot (Jira)
• 2026/10/06 [PR] [FLINK-40735][table] Compare non-time OVER accumulators with a generated equaliser [flink] via GitHub
• 2026/10/06 Re: [PR] [FLINK-36146][connector-base] Fix SingleThreadFetcherManager race condition [flink] via GitHub
• 2026/10/06 [jira] [Commented] (FLINK-40916) Optionally skip eager initialisation of checkpoint locations Isaac Montenegro Jimenez (Jira)
• 2026/10/06 Re: [PR] [FLINK-40913][tests] Use a single vertex job in testStuckSyncPhaseFailsJob to avoid failures race [flink] via GitHub
• 2026/10/06 Re: [PR] [FLINK-40916][runtime] Optionally skip eager initialization of checkpoint base locations [flink] via GitHub
• 2026/10/06 Re: [PR] [FLINK-40909][table-planner] Support filter push down for element access on ARRAY, MAP and VARIANT [flink] via GitHub
• 2026/10/06 [jira] [Updated] (FLINK-40916) Optionally skip eager initialisation of checkpoint locations ASF GitHub Bot (Jira)
• 2026/10/06 Re: [PR] [FLINK-40909][table-planner] Support filter push down for element access on ARRAY, MAP and VARIANT [flink] via GitHub
• 2026/10/06 [PR] [FLINK-40916][runtime] Optionally skip eager initialization of checkpoint base locations [flink] via GitHub
• 2026/10/06 Re: [PR] [FLINK-40644][state/forst] Close the remote stream when a CachedDataInputStream is closed [flink] via GitHub
• 2026/10/06 Re: [PR] [FLINK-33383] [Project Website] Remove deprecated Scala quickstart scripts [flink-web] via GitHub
• 2026/10/06 [jira] [Assigned] (FLINK-40737) COLLECT over a non-time OVER window returns only the current row instead of the running window Martijn Visser (Jira)
• 2026/10/06 Re: [PR] [Backport][FLINK-40368][table] Deduplicate output should only be insert-only when ordered by time attribute [flink] via GitHub
• 2026/10/06 Re: [PR] Add Flink Community Update for Q2 2026 [flink-web] via GitHub
• 2026/10/06 Re: [PR] [Backport][FLINK-39966][FLINK-40368][table] Fix changelog inference for Top-1 ranks not ordered by a time attribute [flink] via GitHub
• 2026/10/06 Re: [PR] [Backport][FLINK-40368][table] Deduplicate output should only be insert-only when ordered by time attribute [flink] via GitHub
• 2026/10/06 [PR] [Backport][FLINK-40368][table] Deduplicate output should only be insert-only when ordered by time attribute [flink] via GitHub
• 2026/10/06 [PR] [Backport][FLINK-39966][FLINK-40368][table] Fix changelog inference for Top-1 ranks not ordered by a time attribute [flink] via GitHub
• 2026/10/06 [PR] [Backport][FLINK-40368][table] Deduplicate output should only be insert-only when ordered by time attribute [flink] via GitHub
• 2026/10/06 Re: [PR] [FLINK-24379] Add Glue Schema Registry SQL formats: Avro, Protobuf, JSON [flink-connector-aws] via GitHub
• 2026/10/06 [PR] [Backport][FLINK-40809][FLINK-40831][FLINK-40841][FLINK-40858][table] Backport streaming join update fixes to 2.2 [flink] via GitHub
• 2026/10/06 Re: [PR] [Backport][FLINK-40809][FLINK-40831][FLINK-40841][FLINK-40858][table] Backport streaming join update fixes to 2.2 [flink] via GitHub
• 2026/10/06 [jira] [Updated] (FLINK-40925) JobVertexBackPressureHandler throws NoSuchElementException when execution attempts are pruned concurrently Martijn Visser (Jira)
• 2026/10/06 Re: [PR] [Backport][FLINK-40809][FLINK-40831][FLINK-40841][FLINK-40858][table] Backport streaming join update fixes to 2.3 [flink] via GitHub
• 2026/10/06 [jira] [Commented] (FLINK-40500) DataStream V2 idleness detection is not backpressure-aware - FLIP-471 was never applied to ExtractEventTimeProcessFunction Martijn Visser (Jira)
• 2026/10/06 [jira] [Commented] (FLINK-40736) Non-time ROWS OVER window emits a malformed row for FIRST_VALUE, LAST_VALUE, LISTAGG, COUNT(DISTINCT), ARRAY_AGG, COLLECT and PERCENTILE Martijn Visser (Jira)
• 2026/10/06 Re: [PR] [FLINK-40909][table-planner] Support filter push down for element access on ARRAY, MAP and VARIANT [flink] via GitHub
• 2026/10/06 [PR] [Backport][FLINK-40809][FLINK-40831][FLINK-40841][FLINK-40858][table] Backport streaming join update fixes to 2.3 [flink] via GitHub
• 2026/10/06 Re: [PR] [FLINK-40912][Connectors/Kafka] Close the exactly-once writer's AdminClient [flink-connector-kafka] via GitHub
• 2026/10/06 Re: [PR] [FLINK-40833] Fix accumulator corruption in NonTimeRowsUnboundedPrecedingFunction [flink] via GitHub
• 2026/10/06 [jira] [Commented] (FLINK-40737) COLLECT over a non-time OVER window returns only the current row instead of the running window Martijn Visser (Jira)
• 2026/10/06 [jira] [Updated] (FLINK-40883) Accumulator corruption in NonTimeRowsUnboundedPrecedingFunction Martijn Visser (Jira)
• 2026/10/06 Re: [PR] [BP-1.20][FLINK-36146][connector-base] Fix SingleThreadFetcherManager race condition [flink] via GitHub
• 2026/10/06 Re: [PR] [BP-2.2][FLINK-36146][connector-base] Fix SingleThreadFetcherManager race condition [flink] via GitHub
• 2026/10/06 Re: [PR] [BP-2.3][FLINK-36146][connector-base] Fix SingleThreadFetcherManager race condition [flink] via GitHub
• 2026/10/06 [jira] [Commented] (FLINK-40735) OVER window ordered by a non-time attribute fails for LAG and ARRAY_AGG when a row arrives out of order Martijn Visser (Jira)
• 2026/10/06 [jira] [Assigned] (FLINK-40735) OVER window ordered by a non-time attribute fails for LAG and ARRAY_AGG when a row arrives out of order Martijn Visser (Jira)
• 2026/10/06 [jira] [Updated] (FLINK-40883) Accumulator corruption in NonTimeRowsUnboundedPrecedingFunction Martijn Visser (Jira)
• 2026/10/06 [jira] [Closed] (FLINK-40736) Non-time ROWS OVER window emits a malformed row for FIRST_VALUE, LAST_VALUE, LISTAGG, COUNT(DISTINCT), ARRAY_AGG, COLLECT and PERCENTILE Martijn Visser (Jira)
• 2026/10/06 Re: [PR] [FLINK-40909][table-planner] Support filter push down for element access on ARRAY, MAP and VARIANT [flink] via GitHub
• 2026/10/06 Re: [PR] [FLINK-40429][python] Add StatementSet support for DataFrame writes [flink] via GitHub
• 2026/10/06 [PR] [BP-2.2][FLINK-36146][connector-base] Fix SingleThreadFetcherManager race condition [flink] via GitHub
• 2026/10/06 [PR] [BP-2.3][FLINK-36146][connector-base] Fix SingleThreadFetcherManager race condition [flink] via GitHub
• 2026/10/06 Re: [PR] [FLINK-40909][table-planner] Support filter push down for element access on ARRAY, MAP and VARIANT [flink] via GitHub
• 2026/10/06 Re: [PR] [FLINK-40909][table-planner] Support filter push down for element access on ARRAY, MAP and VARIANT [flink] via GitHub
• 2026/10/06 [jira] [Updated] (FLINK-36146) NoSuchElement exception from SingleThreadFetcherManager Martijn Visser (Jira)
• 2026/10/06 [PR] [FLINK-40429][python] Add StatementSet support for DataFrame writes [flink] via GitHub
• 2026/10/06 [jira] [Updated] (FLINK-40429) Add StatementSet support for multi-sink DataFrame writes ASF GitHub Bot (Jira)
• 2026/10/06 Re: [PR] [FLINK-38262][table] Add DROP CONNECTION operation [flink] via GitHub
• 2026/10/06 Re: [PR] [FLINK-40644][state/forst] Close the remote stream when a CachedDataInputStream is closed [flink] via GitHub
• 2026/10/06 Re: [PR] [FLINK-40826][table] Support casting ARRAY, MAP, ROW and STRUCTURED to VARIANT [flink] via GitHub
• 2026/10/06 Re: [PR] [FLINK-40909][table-planner] Support filter push down for element access on ARRAY, MAP and VARIANT [flink] via GitHub
• 2026/10/06 Re: [PR] [FLINK-40354][state/forst] Configure the TTL compaction filter for State V2 states [flink] via GitHub
• 2026/10/06 Re: [PR] [FLINK-40645][state/forst] Unregister closed streams from FileCacheEntry#openedStreams [flink] via GitHub
• 2026/10/06 Re: [PR] [FLINK-38262][table] show connections operation [flink] via GitHub
• 2026/10/06 [jira] [Assigned] (FLINK-40913) CheckpointSyncPhaseTimeoutITCase failures race Martijn Visser (Jira)
• 2026/10/06 Re: [PR] [FLINK-40909][table-planner] Support filter push down for element access on ARRAY, MAP and VARIANT [flink] via GitHub
• 2026/10/06 Re: [PR] [FLINK-38262][table] Add DROP CONNECTION operation [flink] via GitHub
• 2026/10/06 [PR] [FLINK-40644][state/forst] Close the remote stream when a CachedDataInputStream is closed [flink] via GitHub
• 2026/10/06 Re: [PR] [FLINK-40644][state/forst] Close the remote stream when a CachedDataInputStream is closed [flink] via GitHub
• 2026/10/06 Re: [PR] [FLINK-40826][table] Support casting ARRAY, MAP, ROW and STRUCTURED to VARIANT [flink] via GitHub
• 2026/10/06 Re: [PR] [FLINK-38262][table] Add DROP CONNECTION operation [flink] via GitHub
• 2026/10/06 [jira] [Commented] (FLINK-40500) DataStream V2 idleness detection is not backpressure-aware - FLIP-471 was never applied to ExtractEventTimeProcessFunction yongfu.gao (Jira)
• 2026/10/06 Re: [PR] [FLINK-40921] Invoke statebackend's close() and dispose() in right order [flink] via GitHub
• 2026/10/06 Re: [PR] [FLINK-24908][table-planner] Show the position and the failing line in parse errors [flink] via GitHub
• 2026/10/06 [jira] [Assigned] (FLINK-40921) Invoke statebackend's close() and dispose() in right order Zakelly Lan (Jira)
• 2026/10/06 Re: [PR] [FLINK-40925][rest] `JobVertexBackPressureHandler` throws `NoSuchElementException` when execution attempts are pruned concurrently [flink] via GitHub
• 2026/10/06 Re: [PR] [FLINK-40218][core] Let callers that already hold parsed JSON build a VARIANT [flink] via GitHub
• 2026/10/06 Re: [PR] [FLINK-40218][core] Let callers that already hold parsed JSON build a VARIANT [flink] via GitHub
• 2026/10/06 [jira] [Commented] (FLINK-18692) AvroSerializationSchema does not work with types generated by avrohugger Amrit Sarkar (Jira)
• 2026/10/06 [PR] [FLINK-40925][rest] `JobVertexBackPressureHandler` throws `NoSuchElementException` when execution attempts are pruned concurrently [flink] via GitHub
• 2026/10/06 [jira] [Updated] (FLINK-40925) JobVertexBackPressureHandler throws NoSuchElementException when execution attempts are pruned concurrently ASF GitHub Bot (Jira)
• 2026/10/06 Re: [PR] [FLINK-40658][table] Preserve null ROW elements in UNNEST [flink] via GitHub
• 2026/10/06 [jira] [Created] (FLINK-40925) JobVertexBackPressureHandler throws NoSuchElementException when execution attempts are pruned concurrently Sergey Nuyanzin (Jira)
• 2026/10/06 [jira] [Closed] (FLINK-40470) Savepoint redeploy loops forever when the deployment attempt fails Robert Metzger (Jira)
• 2026/10/06 [jira] [Updated] (FLINK-40470) Savepoint redeploy loops forever when the deployment attempt fails Robert Metzger (Jira)
• 2026/10/06 Re: [PR] [FLINK-40218][core] Let callers that already hold parsed JSON build a VARIANT [flink] via GitHub
• 2026/10/06 Re: [PR] [FLINK-40218][core] Let callers that already hold parsed JSON build a VARIANT [flink] via GitHub
• 2026/10/06 Re: [PR] [FLINK-39380][table] Add test snapshotting and restoration to ProcessTableFunctionTestHarness [flink] via GitHub
• 2026/10/06 [jira] [Commented] (FLINK-40924) table.exec.sink.upsert-materialize=NONE silently bypasses the require-on-conflict check sepuri sai krishna (Jira)
• 2026/10/06 [jira] [Created] (FLINK-40924) table.exec.sink.upsert-materialize=NONE silently bypasses the require-on-conflict check sepuri sai krishna (Jira)
• 2026/10/06 Re: [PR] [FLINK-40901][table]Fixed the codegen bug w jsonType/Length [flink] via GitHub
• 2026/10/06 [jira] [Updated] (FLINK-40658) UNNEST silently drops null ROW elements from ARRAY ASF GitHub Bot (Jira)
• 2026/10/06 Re: [PR] [FLINK-40218][core] Let callers that already hold parsed JSON build a VARIANT [flink] via GitHub
• 2026/10/06 [PR] [FLINK-40658][table] Preserve null ROW elements in UNNEST [flink] via GitHub
• 2026/10/05 Re: [PR] [FLINK-40218][core] Let callers that already hold parsed JSON build a VARIANT [flink] via GitHub
• 2026/10/05 Re: [PR] [FLINK-40470] Record spec before deployment attempt in savepoint redeploy [flink-kubernetes-operator] via GitHub
• 2026/10/05 Re: [PR] [FLINK-40218][core] Let callers that already hold parsed JSON build a VARIANT [flink] via GitHub
• 2026/10/05 Re: [PR] [FLINK-40218][core] Let callers that already hold parsed JSON build a VARIANT [flink] via GitHub
• 2026/10/05 Re: [PR] [FLINK-39860][runtime] Reduce ArchUnit violations: production code must not call @VisibleForTesting methods [flink] via GitHub
• 2026/10/05 Re: [PR] [FLINK-34376][table] Fix DECIMAL precision loss in multiplication type inference [flink] via GitHub
• 2026/10/05 Re: [PR] [FLINK-37247][FileSystems][Tests] Implement common Hadoop file system integration tests for GCS. [flink] via GitHub
• 2026/10/05 Re: [PR] [FLINK-39860][runtime] Reduce ArchUnit violations: production code must not call @VisibleForTesting methods [flink] via GitHub
• 2026/10/05 Re: [PR] [FLINK-36146][connector-base] Fix SingleThreadFetcherManager race condition [flink] via GitHub
• 2026/10/05 [jira] [Updated] (FLINK-34376) FLINK SQL SUM() causes a precision error ASF GitHub Bot (Jira)
• 2026/10/05 Re: [PR] [FLINK-40057][runtime] Avoid over-picking slots in DefaultSlotAssigner [flink] via GitHub
• 2026/10/05 [jira] [Commented] (FLINK-31737) Hide the rescaling buttons for batch jobs in the WEB UI Amrit Sarkar (Jira)
• 2026/10/05 Re: [PR] [FLINK-40903][runtime/network] Add source host info in TM disconnect error [flink] via GitHub
• 2026/10/05 [jira] [Commented] (FLINK-32212) Job restarting indefinitely after an IllegalStateException from BlobLibraryCacheManager Robert Metzger (Jira)
• 2026/10/05 [PR] [FLINK-40920][table-planner] Fix ClassCastException when reducing a division by a constant expression [flink] via GitHub
• 2026/10/05 Re: [PR] [FLINK-40501][datastream] Keep watermark status ordered with queued watermarks in AsyncWaitOperator [flink] via GitHub
• 2026/10/05 Re: [PR] [FLINK-40836][checkpointing] Keep coordinator state when discarding in-flight data [flink] via GitHub
• 2026/10/05 Re: [PR] [FLINK-40912][Connectors/Kafka] Close the exactly-once writer's AdminClient [flink-connector-kafka] via GitHub
• 2026/10/05 [jira] [Updated] (FLINK-40501) WatermarkStatus overtakes queued watermarks in AsyncWaitOperator, causing watermark loss downstream ASF GitHub Bot (Jira)
• 2026/10/05 Re: [PR] [FLINK-40919][table-planner] Do not reduce AVG on TINYINT, SMALLINT and INT to SUM / COUNT [flink] via GitHub
• 2026/10/05 [jira] [Updated] (FLINK-40836) Restoring with execution.state-recovery.without-channel-state.checkpoint-id drops operator coordinator state ASF GitHub Bot (Jira)
• 2026/10/05 Re: [PR] [FLINK-40922][table-planner] Group keys of an aggregate with grouping sets are not a unique key [flink] via GitHub
• 2026/10/05 [PR] [FLINK-40501][datastream] Keep watermark status ordered with queued watermarks in AsyncWaitOperator [flink] via GitHub
• 2026/10/05 [PR] [FLINK-40836][checkpointing] Keep coordinator state when discarding in-flight data [flink] via GitHub
• 2026/10/05 Re: [PR] [FLINK-40920][table-planner] Fix ClassCastException when reducing a division by a constant expression [flink] via GitHub
• 2026/10/05 [PR] [FLINK-40919][table-planner] Do not reduce AVG on TINYINT, SMALLINT and INT to SUM / COUNT [flink] via GitHub
• 2026/10/05 [jira] [Updated] (FLINK-40919) AVG on INT returns wrong result when the planner rewrites it into SUM/COUNT (INT sum overflows) ASF GitHub Bot (Jira)
• 2026/10/05 [jira] [Updated] (FLINK-40922) DISTINCT over GROUP BY ROLLUP returns duplicate rows ASF GitHub Bot (Jira)
• 2026/10/05 [jira] [Updated] (FLINK-40920) SELECT 1 / (2 + 3) fails with ClassCastException: RexCall cannot be cast to RexLiteral in ExpressionReducer ASF GitHub Bot (Jira)
• 2026/10/05 [PR] [FLINK-40922][table-planner] Group keys of an aggregate with grouping sets are not a unique key [flink] via GitHub
• 2026/10/05 Re: [PR] [FLINK-40826][table] Support casting ARRAY, MAP, ROW and STRUCTURED to VARIANT [flink] via GitHub
• 2026/10/05 [jira] [Created] (FLINK-40923) `a >= b` on DOUBLE NaN keeps the row in one query but drops it when the input is first written to a table (reflexive comparison simplified to TRUE) Yaoxuan Wu (Jira)
• 2026/10/05 Re: [PR] [FLINK-40921] Invoke statebackend's close() and dispose() in right order [flink] via GitHub
• 2026/10/05 [jira] [Updated] (FLINK-40921) Invoke statebackend's close() and dispose() in right order ASF GitHub Bot (Jira)
• 2026/10/05 [PR] [FLINK-40921] Invoke statebackend's close() and dispose() in right order [flink] via GitHub
• 2026/10/05 [jira] [Commented] (FLINK-40470) Savepoint redeploy loops forever when the deployment attempt fails hyeon kim (Jira)
• 2026/10/05 Re: [PR] [FLINK-40470] Record spec before deployment attempt in savepoint redeploy [flink-kubernetes-operator] via GitHub
• 2026/10/05 [jira] [Created] (FLINK-40922) DISTINCT over GROUP BY ROLLUP returns duplicate rows Yaoxuan Wu (Jira)
• 2026/10/05 [jira] [Created] (FLINK-40921) Invoke statebackend's close() and dispose() in right order Zakelly Lan (Jira)

• Earlier messages
• Later messages