issues  

Messages by Date

• 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)
• 2026/10/05 [jira] [Updated] (FLINK-40920) SELECT 1 / (2 + 3) fails with ClassCastException: RexCall cannot be cast to RexLiteral in ExpressionReducer Yaoxuan Wu (Jira)
• 2026/10/05 [jira] [Created] (FLINK-40920) SELECT 1 / (2 + 3) fails with ClassCastException: RexCall cannot be cast to RexLiteral in ExpressionReducer Yaoxuan Wu (Jira)
• 2026/10/05 [jira] [Updated] (FLINK-40919) AVG on INT returns wrong result when the planner rewrites it into SUM/COUNT (INT sum overflows) Yaoxuan Wu (Jira)
• 2026/10/05 [jira] [Created] (FLINK-40919) AVG on INT returns wrong result when the planner rewrites it into SUM/COUNT (INT sum overflows) Yaoxuan Wu (Jira)
• 2026/10/05 Re: [PR] [FLINK-40903][runtime/network] Add source host info in TM disconnect error [flink] via GitHub
• 2026/10/05 Re: [PR] [integration][java][python] Reject media blocks in providers that send text only [flink-agents] via GitHub
• 2026/10/05 Re: [PR] [FLINK-40903][runtime/network] Add source host info in TM disconnect error [flink] via GitHub
• 2026/10/05 Re: [PR] [FLINK-40903][runtime/network] Add source host info in TM disconnect error [flink] via GitHub
• 2026/10/05 Re: [PR] [FLINK-39406][oracle-cdc] Add support for reading from partitioned tables in Oracle connector [flink-cdc] via GitHub
• 2026/10/05 Re: [PR] [FLINK-38907][postgres] Debezium publication filtering data lost [flink-cdc] via GitHub
• 2026/10/05 Re: [PR] [FLINK-39403][cdc-connector] Fix transaction leak during snapshot split read for DB2, Oracle, PostgreSQL, and SQL Server connectors [flink-cdc] via GitHub
• 2026/10/05 Re: [PR] [FLINK-39403][cdc-connector] Fix transaction leak during snapshot split read for DB2, Oracle, PostgreSQL, and SQL Server connectors [flink-cdc] via GitHub
• 2026/10/05 Re: [PR] [FLINK-39406][oracle-cdc] Add support for reading from partitioned tables in Oracle connector [flink-cdc] via GitHub
• 2026/10/05 Re: [PR] [FLINK-40903][runtime/network] Add source host info in TM disconnect error [flink] via GitHub
• 2026/10/05 [jira] [Updated] (FLINK-40903) Add source host info in TM disconnect error ASF GitHub Bot (Jira)
• 2026/10/05 [PR] [FLINK-40903][runtime/network] Add source host info in TM disconnect error [flink] via GitHub
• 2026/10/05 Re: [PR] [FLINK-40835][state] Forward bulk reads in CompressibleFSDataInputStream [flink] via GitHub
• 2026/10/05 [jira] [Updated] (FLINK-40835) Operator state restore reads state files one byte at a time ASF GitHub Bot (Jira)
• 2026/10/05 [PR] [FLINK-40835][state] Forward bulk reads in CompressibleFSDataInputStream [flink] via GitHub
• 2026/10/05 [jira] [Comment Edited] (FLINK-40835) Operator state restore reads state files one byte at a time Amrit Sarkar (Jira)
• 2026/10/05 [jira] [Commented] (FLINK-40835) Operator state restore reads state files one byte at a time Amrit Sarkar (Jira)
• 2026/10/05 Re: [PR] [FLINK-36146][connector-base] Fix SingleThreadFetcherManager race condition [flink] via GitHub
• 2026/10/05 Re: [PR] [FLINK-36146][connector-base] Fix SingleThreadFetcherManager race condition [flink] via GitHub
• 2026/10/05 Re: [PR] [FLINK-36146][connector-base] Fix SingleThreadFetcherManager race condition [flink] via GitHub
• 2026/10/05 [jira] [Created] (FLINK-40918) SIGTERM during application-mode HA recovery permanently fails the suspended jobs of a PyFlink application Ian Stewart (Jira)
• 2026/10/05 Re: [PR] [FLINK-40098][test-utils] Add FailingCheckpointedSource for exactly-once source tests [flink] via GitHub
• 2026/10/05 Re: [PR] [BP-1.20][FLINK-40657][connector-base] Release per-fetcher state in FutureCompletingBlockingQueue. [flink] via GitHub
• 2026/10/05 [jira] [Comment Edited] (FLINK-40657) FutureCompletingBlockingQueue retains a ConditionAndFlag for every SplitFetcher ever created Alexandru (Jira)
• 2026/10/05 [jira] [Commented] (FLINK-40657) FutureCompletingBlockingQueue retains a ConditionAndFlag for every SplitFetcher ever created Alexandru (Jira)
• 2026/10/05 [PR] [BP-1.20][FLINK-40657][connector-base] Release per-fetcher state in FutureCompletingBlockingQueue. [flink] via GitHub
• 2026/10/05 Re: [PR] [FLINK-40139][Connectors/Kafka] test: Add default JUnit test timeout to fail hung tests fast [flink-connector-kafka] via GitHub
• 2026/10/05 Re: [PR] [BP-2.2][FLINK-40657][connector-base] Release per-fetcher state in FutureCompletingBlockingQueue [flink] via GitHub
• 2026/10/05 [PR] [BP-2.2][FLINK-40657][connector-base] Release per-fetcher state in FutureCompletingBlockingQueue [flink] via GitHub
• 2026/10/05 Re: [PR] [BP-2.3][FLINK-40657][connector-base] Release per-fetcher state in FutureCompletingBlockingQueue [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-40901) JSON functions return the result of a previous row when JSON_TYPE or JSON_LENGTH is skipped ASF GitHub Bot (Jira)
• 2026/10/05 Re: [PR] [FLINK-36146][connector-base] Fix SingleThreadFetcherManager race condition [flink] via GitHub
• 2026/10/05 [PR] [BP-2.3][FLINK-40657][connector-base] Release per-fetcher state in FutureCompletingBlockingQueue [flink] via GitHub
• 2026/10/05 Re: [PR] [FLINK-36146][connector-base] Fix SingleThreadFetcherManager race condition [flink] via GitHub
• 2026/10/05 [PR] [FLINK-36146][connector-base] Fix SingleThreadFetcherManager race condition [flink] via GitHub
• 2026/10/05 Re: [PR] [FLINK-40909][table-planner] Support filter push down for element access on ARRAY, MAP and VARIANT [flink] via GitHub
• 2026/10/05 [PR] [FLINK-40909][table-planner] Support filter push down for element access on ARRAY, MAP and VARIANT [flink] via GitHub
• 2026/10/05 [jira] [Updated] (FLINK-40909) Support filter push down for element access on ARRAY, MAP and VARIANT (ITEM) ASF GitHub Bot (Jira)
• 2026/10/05 Re: [PR] [FLINK-40901][table]Fixed the codegen bug w jsonType/Length [flink] via GitHub
• 2026/10/05 [jira] [Commented] (FLINK-40659) SingleThreadFetcherManager reaps and recreates its fetcher on every idle gap Martijn Visser (Jira)
• 2026/10/05 [PR] [FLINK-40901][table]Fixed the codegen bug w jsonType/Length [flink] via GitHub
• 2026/10/05 [jira] [Commented] (FLINK-40657) FutureCompletingBlockingQueue retains a ConditionAndFlag for every SplitFetcher ever created Martijn Visser (Jira)
• 2026/10/05 Re: [PR] [FLINK-40657][connector-base] Release per-fetcher state in FutureCompletingBlockingQueue [flink] via GitHub
• 2026/10/05 Re: [PR] [FLINK-40885][table] Support LATERAL SNAPSHOT join in the Table API [flink] via GitHub
• 2026/10/05 Re: [PR] [FLINK-40885][table] Support LATERAL SNAPSHOT join in the Table API [flink] via GitHub
• 2026/10/05 Re: [PR] [FLINK-40657][connector-base] Release per-fetcher state in FutureCompletingBlockingQueue [flink] via GitHub
• 2026/10/05 [jira] [Updated] (FLINK-40728) [FLIP-607] Migrate Flink off end-of-life OkHttp; keep it off the core classpath Martijn Visser (Jira)
• 2026/10/05 Re: [PR] [FLINK-40833] Fix accumulator corruption in NonTimeRowsUnboundedPrecedingFunction [flink] via GitHub
• 2026/10/05 [jira] [Updated] (FLINK-40218) Let callers that already hold parsed JSON build a Variant without a String round trip Ramin Gharib (Jira)
• 2026/10/05 [jira] [Updated] (FLINK-40218) Allow building a Variant from a token source, without a String round-trip Ramin Gharib (Jira)
• 2026/10/05 [jira] [Updated] (FLINK-40218) Allow building a Variant from a token source, without a String round-trip Ramin Gharib (Jira)
• 2026/10/05 Re: [PR] Avoid full left-state scan in TemporalJoin by creating efficient minheap over statafull map [flink] via GitHub
• 2026/10/05 Re: [PR] [FLINK-40728][k8s][build] Migrate Flink off end-of-life OkHttp and keep it off the core classpath (FLIP-607) [flink] via GitHub
• 2026/10/05 Re: [PR] [integration][java][python] Reject media blocks in providers that send text only [flink-agents] via GitHub
• 2026/10/05 Re: [PR] Avoid full left-state scan in TemporalJoin by creating efficient minheap over statafull map [flink] via GitHub
• 2026/10/05 Re: [PR] [integration][java][python] Reject media blocks in providers that send text only [flink-agents] via GitHub
• 2026/10/05 Re: [PR] [FLINK-40806][table] Add PARSE_XML and TRY_PARSE_XML functions [flink] via GitHub
• 2026/10/05 [PR] [api][integrations] Use DashScope naming consistently [flink-agents] via GitHub
• 2026/10/05 Re: [PR] [api][java][python] Restore built-in event types at the JSON boundary [flink-agents] via GitHub
• 2026/10/05 Re: [I] [Tech Debt][API][Python Bridge] Move concrete Python resource wrappers to the Plan module [flink-agents] via GitHub
• 2026/10/05 Re: [PR] [api][java][python] Restore built-in event types at the JSON boundary [flink-agents] via GitHub
• 2026/10/05 Re: [PR] [api][plan][java][python] Separate cross-language resource declarations from wrappers [flink-agents] via GitHub
• 2026/10/05 Re: [PR] [FLINK-40885][table] Support LATERAL SNAPSHOT join in the Table API [flink] via GitHub
• 2026/10/05 [jira] [Resolved] (FLINK-40890) LATERAL SNAPSHOT build side passes TRY_RESOLVE with non-deterministic columns Fabian Hueske (Jira)
• 2026/10/05 Re: [PR] [FLINK-40890][table] Require deterministic build columns for LATERAL SNAPSHOT join [flink] via GitHub
• 2026/10/05 Re: [PR] [FLINK-40896][table]Deduplicate keep first implementation [flink] via GitHub
• 2026/10/05 [jira] [Assigned] (FLINK-40916) Optionally skip eager initialisation of checkpoint locations Martijn Visser (Jira)
• 2026/10/05 [jira] [Comment Edited] (FLINK-27849) Harden correctness for non-deterministic updates present in the changelog pipeline lincoln lee (Jira)
• 2026/10/05 [jira] [Commented] (FLINK-27849) Harden correctness for non-deterministic updates present in the changelog pipeline lincoln lee (Jira)
• 2026/10/05 Re: [I] [Tech Debt][API][Python Bridge] Move concrete Python resource wrappers to the Plan module [flink-agents] via GitHub
• 2026/10/05 [jira] [Closed] (FLINK-28743) Support validating the determinism for StreamPhysicalMatchRecognize lincoln lee (Jira)
• 2026/10/05 [jira] [Created] (FLINK-40917) Deeply nested VARIANT values overflow the stack in toJson(), CAST to STRING and the variant builder Ramin Gharib (Jira)
• 2026/10/05 Re: [PR] [api][runtime][java][python] Simplify agent output materialization with typed toDataStream/toTable [flink-agents] via GitHub
• 2026/10/05 [jira] [Commented] (FLINK-40915) Relax non-deterministic join-condition check for LATERAL SNAPSHOT join Gustavo de Morais (Jira)
• 2026/10/05 Re: [PR] [api][runtime][java][python] Simplify agent output materialization with typed toDataStream/toTable [flink-agents] 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 Re: [PR] [api][runtime][java][python] Simplify agent output materialization with typed toDataStream/toTable [flink-agents] via GitHub
• 2026/10/05 [jira] [Commented] (FLINK-40894) Expose counters for unmatched retractions in SinkUpsertMaterializer and KeyedLookupJoinWrapper yongfu.gao (Jira)
• 2026/10/05 [jira] [Resolved] (FLINK-40825) Support casting primitive types to VARIANT Ramin Gharib (Jira)
• 2026/10/05 [jira] [Commented] (FLINK-40858) Streaming join should evaluate non-equi conditions on key-only deletes Gustavo de Morais (Jira)
• 2026/10/05 Re: [PR] [FLINK-40890][table] Require deterministic build columns for LATERAL SNAPSHOT join [flink] via GitHub
• 2026/10/05 [jira] [Created] (FLINK-40916) Optionally skip eager initialisation of checkpoint locations Isaac Montenegro Jimenez (Jira)
• 2026/10/05 Re: [PR] [FLINK-40844][table] Only EXPR$0 when a PTF's whole output is empty [flink] via GitHub
• 2026/10/05 Re: [PR] [FLINK-40871][table] Avoid the UTF-8 round trip when casting strings and decimals to VARIANT [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 Re: [PR] [FLINK-40826][table] Support casting ARRAY, MAP, ROW and STRUCTURED to VARIANT [flink] via GitHub
• 2026/10/05 [jira] [Resolved] (FLINK-40871) Avoid the UTF-8 round trip when casting strings and decimals to VARIANT Ramin Gharib (Jira)
• 2026/10/05 Re: [PR] Avoid full left-state scan in TemporalJoin by creating efficient minheap over statafull map [flink] via GitHub
• 2026/10/05 [jira] [Commented] (FLINK-28440) EventTimeWindowCheckpointingITCase failed with restore Martijn Visser (Jira)

• Earlier messages
• Later messages