issues  

Messages by Date

• 2026/10/08 Re: [PR] [FLINK-40949][table-runtime] Fail with a clear error on NULL window bounds in windowed assigners [flink] via GitHub
• 2026/10/08 [jira] [Commented] (FLINK-27963) FlinkRuntimeException in KafkaSink causes a Flink job to hang Martijn Visser (Jira)
• 2026/10/08 Re: [PR] [FLINK-40737][table] Keep non-time OVER data views inside the accumulator [flink] via GitHub
• 2026/10/08 [jira] [Updated] (FLINK-40788) 'Heavy deployment end-to-end test' fails because all TaskManagers run out of memory on Java 11 Martijn Visser (Jira)
• 2026/10/08 [jira] [Updated] (FLINK-35012) ChangelogNormalizeRestoreTest.testRestore failure Martijn Visser (Jira)
• 2026/10/08 [jira] [Updated] (FLINK-35012) ChangelogNormalizeRestoreTest.testRestore failure Martijn Visser (Jira)
• 2026/10/08 Re: [PR] [FLINK-40737][table] Keep non-time OVER data views inside the accumulator [flink] via GitHub
• 2026/10/08 [jira] [Commented] (FLINK-33082) Azure Pipelines 4 is not responding on AZP Martijn Visser (Jira)
• 2026/10/08 [jira] [Commented] (FLINK-35012) ChangelogNormalizeRestoreTest.testRestore failure Martijn Visser (Jira)
• 2026/10/08 [jira] [Commented] (FLINK-33690) build_wheels_on_macos sometimes fails with read timed out on AZP Martijn Visser (Jira)
• 2026/10/08 [jira] [Commented] (FLINK-34523) Some jar couldn't be downloaded from google-maven-central Martijn Visser (Jira)
• 2026/10/08 [jira] [Commented] (FLINK-40788) 'Heavy deployment end-to-end test' fails because all TaskManagers run out of memory on Java 11 Martijn Visser (Jira)
• 2026/10/08 [jira] [Commented] (FLINK-40132) MixedKubernetesServerExtension teardown flaky with RejectedExecutionException from Fabric8 Vert.x mock server shutdown Martijn Visser (Jira)
• 2026/10/08 [jira] [Commented] (FLINK-39330) FileSourceTextLinesITCase.testBoundedTextFileSourceWithJobManagerFailove fails Martijn Visser (Jira)
• 2026/10/08 [jira] [Commented] (FLINK-40663) WindowDistinctAggregateStressITCase.testCumulateWindowRollupUnderBackpressure times out after 600s Martijn Visser (Jira)
• 2026/10/08 Re: [PR] [FLINK-40735][table] Compare non-time OVER accumulators with a generated equaliser [flink] via GitHub
• 2026/10/08 Re: [PR] [FLINK-40735][table] Compare non-time OVER accumulators with a generated equaliser [flink] via GitHub
• 2026/10/08 [jira] [Commented] (FLINK-30644) ChangelogCompatibilityITCase.testRestore fails due to CheckpointCoordinator being shutdown Martijn Visser (Jira)
• 2026/10/08 Re: [PR] [FLINK-40735][table] Compare non-time OVER accumulators with a generated equaliser [flink] via GitHub
• 2026/10/08 [jira] [Commented] (FLINK-38613) UnalignedCheckpointRescaleWithMixedExchangesITCase.testRescaleFromUnalignedCheckpoint failed in test_cron_jdk11 tests Martijn Visser (Jira)
• 2026/10/08 [jira] [Updated] (FLINK-39330) FileSourceTextLinesITCase.testBoundedTextFileSourceWithJobManagerFailove fails Martijn Visser (Jira)
• 2026/10/08 [jira] [Commented] (FLINK-40887) TaskFailureITCase.testJobWithoutObjectReuse fails with "Expecting Optional to contain a value but it was empty" Martijn Visser (Jira)
• 2026/10/08 [jira] [Commented] (FLINK-40664) JobIDLoggingITCase.testJobIDLogging fails on a "Freeing inactive slots" log line without the job id Martijn Visser (Jira)
• 2026/10/08 [jira] [Commented] (FLINK-40793) DefaultSchedulerTest is unstable across many test methods Martijn Visser (Jira)
• 2026/10/08 [jira] [Commented] (FLINK-34427) FineGrainedSlotManagerTest fails fatally (exit code 239) Martijn Visser (Jira)
• 2026/10/08 Re: [PR] [FLINK-40940][connector-http] Emit null enrichment row for failed lookup calls with continue-on-error [flink-connector-http] via GitHub
• 2026/10/08 [jira] [Commented] (FLINK-40887) TaskFailureITCase.testJobWithoutObjectReuse fails with "Expecting Optional to contain a value but it was empty" Gautham Sankar V (Jira)
• 2026/10/08 Re: [PR] [api][plan][runtime][python] Support registering an Agent as an in-process internal sub-agent [flink-agents] via GitHub
• 2026/10/08 Re: [PR] [FLINK-40940][connector-http] Emit null enrichment row for failed lookup calls with continue-on-error [flink-connector-http] via GitHub
• 2026/10/08 [jira] [Created] (FLINK-40957) MongoDB CDC encodes spaces as '+' instead of '%20' in credentials luana (Jira)
• 2026/10/08 Re: [PR] [api][plan][runtime][python] Support registering an Agent as an in-process internal sub-agent [flink-agents] via GitHub
• 2026/10/08 Re: [PR] [api][plan][runtime][python] Support registering an Agent as an in-process internal sub-agent [flink-agents] via GitHub
• 2026/10/08 [jira] [Commented] (FLINK-40789) RescaleTimelineITCase.testRecordRescaleForNewAvailableResource records three rescales instead of two Naveen Joseph (Jira)
• 2026/10/08 [jira] [Updated] (FLINK-40952) ForSt: rescale restore never closes the temporary DB's DBOptions copy, leaking the slot-shared block cache ASF GitHub Bot (Jira)
• 2026/10/08 [jira] [Updated] (FLINK-40951) Sync Chinese docs of Flink source connectors with English docs ASF GitHub Bot (Jira)
• 2026/10/08 [jira] [Commented] (FLINK-40952) ForSt: rescale restore never closes the temporary DB's DBOptions copy, leaking the slot-shared block cache Yordan Pavlov (Jira)
• 2026/10/08 [jira] [Updated] (FLINK-40953) Store the native S3 recoverable writer tail under the target directory ASF GitHub Bot (Jira)
• 2026/10/08 [jira] [Created] (FLINK-40956) Fall back to stateless delete when savepoint on deletion keeps failing Gyula Fora (Jira)
• 2026/10/08 [jira] [Created] (FLINK-40955) Give up and remove finalizer after cleanup keeps failing with a timeout Gyula Fora (Jira)
• 2026/10/08 [jira] [Created] (FLINK-40954) Force delete pods stuck Terminating on cluster resource cleanup timeout Gyula Fora (Jira)
• 2026/10/08 [jira] [Created] (FLINK-40953) Store the native S3 recoverable writer tail under the target directory Gabor Somogyi (Jira)
• 2026/10/08 [jira] [Commented] (FLINK-40927) Inconsistent NaN semantics for FLOAT/DOUBLE across planner and runtime Yahya Kisana (Jira)
• 2026/10/08 [jira] [Created] (FLINK-40952) ForSt: rescale restore never closes the temporary DB's DBOptions copy, leaking the slot-shared block cache Yordan Pavlov (Jira)
• 2026/10/08 Re: [I] [Tech Debt][API][ReActAgent] Support Skills directly in Java and Python constructors [flink-agents] via GitHub
• 2026/10/08 [jira] [Commented] (FLINK-40951) Sync Chinese docs of Flink source connectors with English docs Xiqian Yu (Jira)
• 2026/10/08 [jira] [Assigned] (FLINK-40951) Sync Chinese docs of Flink source connectors with English docs Xiqian Yu (Jira)
• 2026/10/08 [jira] [Closed] (FLINK-40437) Add iteration and bounded retrieval to DataFrame API Dian Fu (Jira)
• 2026/10/08 Re: [PR] [api][java][python] Restore built-in event types at the JSON boundary [flink-agents] via GitHub
• 2026/10/08 [jira] [Assigned] (FLINK-40789) RescaleTimelineITCase.testRecordRescaleForNewAvailableResource records three rescales instead of two Martijn Visser (Jira)
• 2026/10/08 [jira] [Closed] (FLINK-40429) Add StatementSet support for multi-sink DataFrame writes Dian Fu (Jira)
• 2026/10/08 Re: [PR] [FLINK-40912][Connectors/Kafka] Close the exactly-once writer's AdminClient [flink-connector-kafka] via GitHub
• 2026/10/08 [jira] [Assigned] (FLINK-40949) WindowedUnsliceAssigner reports a NULL window bound as "RowTime field should not be null." Martijn Visser (Jira)
• 2026/10/08 Re: [PR] [FLINK-40949][table-runtime] Fail with a clear error on NULL window bounds in windowed assigners [flink] via GitHub
• 2026/10/08 Re: [PR] [FLINK-40950][table-planner] Drop stale metadata=[] from EarlyFireJoinHintTest plan [flink] via GitHub
• 2026/10/08 Re: [PR] [build] Bump version to 3.8-SNAPSHOT [flink-cdc] via GitHub
• 2026/10/08 Re: [PR] [FLINK-40392][jdbc] Add BoundaryQuerySplitterEnumerator for scan.partition.boundary-query [flink-connector-jdbc] via GitHub
• 2026/10/08 [jira] [Created] (FLINK-40951) Sync Chinese docs of Flink source connectors with English docs peiyu (Jira)
• 2026/10/08 Re: [PR] [FLINK-24379][Formats] Avro Glue Schema Registry table format [flink-connector-aws] via GitHub
• 2026/10/08 Re: [PR] [FLINK-24379][Formats] Avro Glue Schema Registry table format [flink-connector-aws] via GitHub
• 2026/10/07 Re: [PR] [FLINK-40429][python] Add StatementSet support for DataFrame writes [flink] via GitHub
• 2026/10/07 [jira] [Commented] (FLINK-40327) ForSt async multiGet leaks a native ReadOptions per read batch Yordan Pavlov (Jira)
• 2026/10/07 Re: [PR] [FLINK-38753] [table-planner] Enrich upsert keys by equi-join equivalences [flink] via GitHub
• 2026/10/07 Re: [PR] [FLINK-38753] [table-planner] Enrich upsert keys by equi-join equivalences [flink] via GitHub
• 2026/10/07 [PR] [FLINK-40951][docs] Translate Flink source connector docs into Chinese [flink-cdc] via GitHub
• 2026/10/07 Re: [I] [Tech Debt][API][ChatMessage] Add raw-bytes factory methods for media blocks [flink-agents] via GitHub
• 2026/10/07 Re: [PR] [api][java][python] Add raw-bytes factories for media blocks [flink-agents] via GitHub
• 2026/10/07 [PR] [FLINK-40940][connector-http] Emit null enrichment row for failed lookup calls with continue-on-error [flink-connector-http] via GitHub
• 2026/10/07 [jira] [Updated] (FLINK-40940) HTTP lookup source drops the row for a failed call with continue-on-error unless the planner calls applyReadableMetadata ASF GitHub Bot (Jira)
• 2026/10/07 Re: [I] [Tech Debt][API][Model Routing] Unify handling of runtime non-candidate selections [flink-agents] via GitHub
• 2026/10/07 Re: [PR] [api][plan] Abstain on runtime non-candidate model selections [flink-agents] via GitHub
• 2026/10/07 Re: [PR] [integration][observability] Add OpenTelemetry GenAI exporter for Agent Traces (Phase 1) [flink-agents] via GitHub
• 2026/10/07 Re: [PR] [FLINK-40294][table-planner] Instrument async scalar and table UDF calls with metrics [flink] via GitHub
• 2026/10/07 [jira] [Commented] (FLINK-40172) Support processing-time early fire on a row-time interval join Weiqing Yang (Jira)
• 2026/10/07 [jira] [Comment Edited] (FLINK-40172) Support processing-time early fire on a row-time interval join Weiqing Yang (Jira)
• 2026/10/07 [jira] [Comment Edited] (FLINK-40172) Support processing-time early fire on a row-time interval join Weiqing Yang (Jira)
• 2026/10/07 [jira] [Comment Edited] (FLINK-40172) Support processing-time early fire on a row-time interval join Weiqing Yang (Jira)
• 2026/10/07 Re: [PR] [api][integrations][java][python] Ask each connection whether it could apply a schema natively [flink-agents] via GitHub
• 2026/10/07 [jira] [Assigned] (FLINK-40173) Add restore coverage for early-fire interval join Weiqing Yang (Jira)
• 2026/10/07 Re: [PR] Add Flink CDC 3.7.0 release blog [flink-web] via GitHub
• 2026/10/07 Re: [PR] [FLINK-40173][table-planner] Add restore coverage for early-fire interval join [flink] via GitHub
• 2026/10/07 Re: [PR] [FLINK-40172][table-runtime] Support processing-time early fire on a row-time interval join [flink] via GitHub
• 2026/10/07 Re: [PR] [hotfix][table-planner] Drop stale metadata=[] from the early-fire proctime golden [flink] via GitHub
• 2026/10/07 Re: [PR] [hotfix][table-planner] Drop stale metadata=[] from the early-fire proctime golden [flink] via GitHub
• 2026/10/07 Re: [PR] [FLINK-40172][table-runtime] Support processing-time early fire on a row-time interval join [flink] via GitHub
• 2026/10/07 [PR] [hotfix][table-planner] Drop stale metadata=[] from the early-fire proctime golden [flink] via GitHub
• 2026/10/07 Re: [I] [Umbrella] Pluggable model routing (MODEL_ROUTER): delivery status, Python parity, documentation, and follow-ups [flink-agents] via GitHub
• 2026/10/07 [jira] [Commented] (FLINK-36419) Consider scaling in case of no input records on a source operator with long running job Sergey Kononov (Jira)
• 2026/10/07 [jira] [Closed] (FLINK-36419) Consider scaling in case of no input records on a source operator with long running job Sergey Kononov (Jira)
• 2026/10/07 [jira] [Closed] (FLINK-35892) Flink Kubernetes Operator docs lacks info on FlinkSessionJob submission Sergey Kononov (Jira)
• 2026/10/07 [jira] [Commented] (FLINK-35892) Flink Kubernetes Operator docs lacks info on FlinkSessionJob submission Sergey Kononov (Jira)
• 2026/10/07 [PR] [api][java][python] Add raw-bytes factories for media blocks [flink-agents] via GitHub
• 2026/10/07 Re: [PR] [api][runtime][java][python] Simplify agent output materialization with typed toDataStream/toTable [flink-agents] via GitHub
• 2026/10/07 [jira] [Commented] (FLINK-40856) Support zip-style multi-column explode in DataFrame API Bettle (Jira)
• 2026/10/07 [jira] [Commented] (FLINK-40856) Support zip-style multi-column explode in DataFrame API Dian Fu (Jira)
• 2026/10/07 Re: [PR] [FLINK-39797] Support disabling automatic table creation [flink-cdc] via GitHub
• 2026/10/07 [jira] [Updated] (FLINK-40856) Support zip-style multi-column explode in DataFrame API Dian Fu (Jira)
• 2026/10/07 [jira] [Comment Edited] (FLINK-40856) Support zip-style multi-column explode in DataFrame API Dian Fu (Jira)
• 2026/10/07 [jira] [Commented] (FLINK-40856) Support zip-style multi-column explode in DataFrame API Dian Fu (Jira)
• 2026/10/07 Re: [I] [Bug] [runtime][python] Successful durable calls swallow Java state persistence failures [flink-agents] via GitHub
• 2026/10/07 Re: [I] [Bug][runtime][python] Durable call exceptions that fail to pickle or unpickle are lost or replayed as TypeError [flink-agents] via GitHub
• 2026/10/07 Re: [PR] [api][plan][runtime][python] Support registering an Agent as an in-process internal sub-agent [flink-agents] via GitHub
• 2026/10/07 [PR] [api][runtime][python] Support running a ReActAgent as a general-purpose sub-agent [flink-agents] via GitHub
• 2026/10/07 Re: [PR] [api][integrations][java][python] Ask each connection whether it could apply a schema natively [flink-agents] via GitHub
• 2026/10/07 Re: [PR] [Tech Debt] align action recovery model [flink-agents] via GitHub
• 2026/10/07 Re: [PR] [FLINK-40740][pipeline-connector/fluss] Prevent duplicate split initialization during discovery [flink-cdc] via GitHub
• 2026/10/07 Re: [PR] [FLINK-39415][postgres] Fix TIMESTAMPTZ type mapping in pipeline connector [flink-cdc] via GitHub
• 2026/10/07 Re: [PR] [FLINK-39412][cdc-common] Skip duplicate columns in AddColumnEvent to ensure idempotency [flink-cdc] via GitHub
• 2026/10/07 Re: [PR] [FLINK-39412][cdc-common] Skip duplicate columns in AddColumnEvent to ensure idempotency [flink-cdc] via GitHub
• 2026/10/07 Re: [PR] [FLINK-39415][postgres] Fix TIMESTAMPTZ type mapping in pipeline connector [flink-cdc] via GitHub
• 2026/10/07 [jira] [Updated] (FLINK-40908) HBaseITCase.test fails with expected: <6> but was: <0> ASF GitHub Bot (Jira)
• 2026/10/07 Re: [PR] [FLINK-40908][Connectors/HBase] Update bundled hbase-default.xml and NOTICE to HBase 2.6.6 [flink-connector-hbase] via GitHub
• 2026/10/07 [PR] [FLINK-40908][Connectors/HBase] Update bundled hbase-default.xml and NOTICE to HBase 2.6.6 [flink-connector-hbase] via GitHub
• 2026/10/07 [jira] [Commented] (FLINK-40950) EarlyFireJoinHintTest.testEarlyFireProcTimeOnRowTimeJoin fails with unexpected output Yahya Kisana (Jira)
• 2026/10/07 [jira] [Resolved] (FLINK-40925) JobVertexBackPressureHandler throws NoSuchElementException when execution attempts are pruned concurrently Sergey Nuyanzin (Jira)
• 2026/10/07 [jira] [Commented] (FLINK-40925) JobVertexBackPressureHandler throws NoSuchElementException when execution attempts are pruned concurrently Sergey Nuyanzin (Jira)
• 2026/10/07 Re: [PR] [FLINK-40925][rest] `JobVertexBackPressureHandler` throws `NoSuchElementException` when execution attempts are pruned concurrently [flink] via GitHub
• 2026/10/07 Re: [PR] [hotfix][table] Fix `EarlyFireJoinHintTest#testEarlyFireProcTimeOnRowTimeJoin` [flink] via GitHub
• 2026/10/07 Re: [PR] [FLINK-40883][table] Fix accumulator corruption in NonTimeRowsUnboundedPrecedingFunction [flink] via GitHub
• 2026/10/07 [jira] [Commented] (FLINK-40950) EarlyFireJoinHintTest.testEarlyFireProcTimeOnRowTimeJoin fails with unexpected output Yahya Kisana (Jira)
• 2026/10/07 Re: [PR] [hotfix][table] Fix `EarlyFireJoinHintTest#testEarlyFireProcTimeOnRowTimeJoin` [flink] via GitHub
• 2026/10/07 [jira] [Commented] (FLINK-40927) Inconsistent NaN semantics for FLOAT/DOUBLE across planner and runtime Sergey Nuyanzin (Jira)
• 2026/10/07 Re: [PR] [FLINK-32806][runtime] Support eviction of clean job result entries in EmbeddedJobResultStore [flink] via GitHub
• 2026/10/07 Re: [PR] [FLINK-40476][docs] Clarify that the Changelog state backend requires CLAIM restore mode [flink] via GitHub
• 2026/10/07 Re: [PR] [FLINK-32806][runtime] Support eviction of clean job result entries in EmbeddedJobResultStore [flink] via GitHub
• 2026/10/07 Re: [PR] [FLINK-32806][runtime] Support eviction of clean job result entries in EmbeddedJobResultStore [flink] via GitHub
• 2026/10/07 Re: [PR] [FLINK-40797][table-planner] Exclude NestedLoopJoin from CBO search space for equi-joins [flink] via GitHub
• 2026/10/07 Re: [PR] [FLINK-40950][table-planner] Drop stale metadata=[] from EarlyFireJoinHintTest plan [flink] via GitHub
• 2026/10/07 Re: [PR] Revert "[feature] Add flink-stateful-ops-agent-demo: a stateful runbook agent for Flink 2.2 balanced tasks scheduling (#10)" [flink-agents-demos] via GitHub
• 2026/10/07 Re: [PR] [FLINK-40950][table-planner] Drop stale metadata=[] from EarlyFireJoinHintTest plan [flink] via GitHub
• 2026/10/07 Re: [PR] [FLINK-40950][table-planner] Drop stale metadata=[] from EarlyFireJoinHintTest plan [flink] via GitHub
• 2026/10/07 [PR] Revert "[feature] Add flink-stateful-ops-agent-demo: a stateful runbook agent for Flink 2.2 balanced tasks scheduling (#10)" [flink-agents-demos] via GitHub
• 2026/10/07 Re: [PR] [feature] Add flink-stateful-ops-agent-demo: a stateful runbook agent for Flink 2.2 balanced tasks scheduling [flink-agents-demos] via GitHub
• 2026/10/07 [PR] [feature] Add flink-stateful-ops-agent-demo: a stateful runbook agent for Flink 2.2 balanced tasks scheduling [flink-agents-demos] via GitHub
• 2026/10/07 [jira] [Commented] (FLINK-40849) UNION ALL fails for RAW/BITMAP columns with different nullability Charan Rathore (Jira)
• 2026/10/07 [jira] [Commented] (FLINK-40950) EarlyFireJoinHintTest.testEarlyFireProcTimeOnRowTimeJoin fails with unexpected output Yahya Kisana (Jira)
• 2026/10/07 [PR] [FLINK-40476][docs] Clarify that the Changelog state backend requires CLAIM restore mode [flink] via GitHub
• 2026/10/07 [jira] [Updated] (FLINK-40950) EarlyFireJoinHintTest.testEarlyFireProcTimeOnRowTimeJoin fails with unexpected output ASF GitHub Bot (Jira)
• 2026/10/07 [PR] [FLINK-40950][table-planner] Drop stale metadata=[] from EarlyFireJoinHintTest plan [flink] via GitHub
• 2026/10/07 [jira] [Commented] (FLINK-40476) Clarify that the Changelog state backend requires CLAIM restore mode (NO_CLAIM unsupported) Ravikiran kalal (Jira)
• 2026/10/07 Re: [PR] [hotfix][table] Fix `EarlyFireJoinHintTest#testEarlyFireProcTimeOnRowTimeJoin` [flink] via GitHub
• 2026/10/07 [jira] [Commented] (FLINK-40950) EarlyFireJoinHintTest.testEarlyFireProcTimeOnRowTimeJoin fails with unexpected output Yahya Kisana (Jira)
• 2026/10/07 [PR] [hotfix][table] Fix `EarlyFireJoinHintTest#testEarlyFireProcTimeOnRowTimeJoin` [flink] via GitHub
• 2026/10/07 Re: [PR] [FLINK-40948][table] Maintain window properties for different joins [flink] via GitHub
• 2026/10/07 Re: [PR] [FLINK-40949][table-runtime] Fail with a clear error on NULL window bounds in windowed assigners [flink] via GitHub
• 2026/10/07 [jira] [Updated] (FLINK-40949) WindowedUnsliceAssigner reports a NULL window bound as "RowTime field should not be null." ASF GitHub Bot (Jira)
• 2026/10/07 Re: [PR] [FLINK-40883][table] Fix accumulator corruption in NonTimeRowsUnboundedPrecedingFunction [flink] via GitHub
• 2026/10/07 Re: [PR] [FLINK-40943][filesystems] Restore FileSink state written with flink-s3-fs-hadoop in flink-s3-fs-native [flink] via GitHub
• 2026/10/07 [jira] [Updated] (FLINK-40948) Planner crashes with "Type mismatch" when a window aggregate groups on the nullable side of an outer window join ASF GitHub Bot (Jira)
• 2026/10/07 [PR] [FLINK-40949][table-runtime] Fail with a clear error on NULL window bounds in windowed assigners [flink] via GitHub
• 2026/10/07 [PR] [FLINK-40948][table] Maintain window properties for different joins [flink] via GitHub
• 2026/10/07 Re: [PR] [FLINK-40883][table] Fix accumulator corruption in NonTimeRowsUnboundedPrecedingFunction [flink] via GitHub
• 2026/10/07 [jira] [Commented] (FLINK-40172) Support processing-time early fire on a row-time interval join Martijn Visser (Jira)
• 2026/10/07 [jira] [Created] (FLINK-40950) EarlyFireJoinHintTest.testEarlyFireProcTimeOnRowTimeJoin fails with unexpected output Martijn Visser (Jira)
• 2026/10/07 Re: [PR] [FLINK-40172][table-runtime] Support processing-time early fire on a row-time interval join [flink] via GitHub
• 2026/10/07 [jira] [Commented] (FLINK-40949) WindowedUnsliceAssigner reports a NULL window bound as "RowTime field should not be null." Yahya Kisana (Jira)
• 2026/10/07 [jira] [Commented] (FLINK-40929) SUM on DECIMAL silently returns a wrong, order-dependent value after an overflow Charan Rathore (Jira)
• 2026/10/07 Re: [PR] [FLINK-39883][table] Support broadcast state for process table functions [flink] via GitHub
• 2026/10/07 Re: [PR] [FLINK-40912][Connectors/Kafka] Close the exactly-once writer's AdminClient [flink-connector-kafka] via GitHub
• 2026/10/07 [jira] [Closed] (FLINK-40934) Table API row() fails when AS aliases produce duplicate field names Ramin Gharib (Jira)
• 2026/10/07 [jira] [Assigned] (FLINK-40948) Planner crashes with "Type mismatch" when a window aggregate groups on the nullable side of an outer window join Sergey Nuyanzin (Jira)
• 2026/10/07 Re: [PR] [FLINK-39883][table] Support broadcast state for process table functions [flink] via GitHub
• 2026/10/07 [jira] [Created] (FLINK-40949) WindowedUnsliceAssigner reports a NULL window bound as "RowTime field should not be null." Martijn Visser (Jira)
• 2026/10/07 [jira] [Created] (FLINK-40945) -0.0 and 0.0 are different keys in GROUP BY, DISTINCT, UNION and hash joins Yaoxuan Wu (Jira)
• 2026/10/07 [jira] [Created] (FLINK-40948) Planner crashes with "Type mismatch" when a window aggregate groups on the nullable side of an outer window join Martijn Visser (Jira)
• 2026/10/07 [jira] [Created] (FLINK-40946) SUM / AVG on DECIMAL(38, s) over a join are rounded to scale 6 Yaoxuan Wu (Jira)
• 2026/10/07 Re: [PR] [FLINK-39883][table] Support broadcast state for process table functions [flink] via GitHub
• 2026/10/07 [jira] [Created] (FLINK-40947) ROLLUP / CUBE / GROUPING SETS with () return no grand-total row on an empty input Yaoxuan Wu (Jira)
• 2026/10/07 Re: [PR] [FLINK-40943][filesystems] Restore FileSink state written with flink-s3-fs-hadoop in flink-s3-fs-native [flink] via GitHub
• 2026/10/07 [jira] [Updated] (FLINK-40945) -0.0 and 0.0 are different keys in GROUP BY, DISTINCT, UNION and hash joins Yaoxuan Wu (Jira)
• 2026/10/07 Re: [PR] [FLINK-40936][table] Reject VARIANT elements and keys in functions that compare them [flink] via GitHub
• 2026/10/07 Re: [PR] [FLINK-40844][table] Only EXPR$0 when a PTF's whole output is empty [flink] via GitHub
• 2026/10/07 [jira] [Updated] (FLINK-40933) BETWEEN with equal bounds drops trailing spaces of the bound Yaoxuan Wu (Jira)
• 2026/10/07 [jira] [Updated] (FLINK-40933) BETWEEN with equal bounds drops trailing spaces of the bound Yaoxuan Wu (Jira)
• 2026/10/07 [jira] [Updated] (FLINK-40935) VAR_SAMP / STDDEV_SAMP return -1 for a group with a single row Yaoxuan Wu (Jira)
• 2026/10/07 [jira] [Updated] (FLINK-40944) CPU limit-factor inflates the JVM's availableProcessors() to the CPU limit Jira
• 2026/10/07 Re: [PR] [FLINK-40277][connector-http] Add HTTP sink status-code handling and retries [flink-connector-http] via GitHub
• 2026/10/07 [PR] [FLINK-40938][Connectors/DynamoDB] Support AT_TIMESTAMP initial position in DynamoDB Streams source [flink-connector-aws] via GitHub
• 2026/10/07 Re: [PR] [FLINK-40883][table] Fix accumulator corruption in NonTimeRowsUnboundedPrecedingFunction [flink] via GitHub
• 2026/10/07 [jira] [Updated] (FLINK-40883) Accumulator corruption in NonTimeRowsUnboundedPrecedingFunction ASF GitHub Bot (Jira)
• 2026/10/07 Re: [PR] [FLINK-40883][table] Fix accumulator corruption in NonTimeRowsUnboundedPrecedingFunction [flink] via GitHub
• 2026/10/07 Re: [PR] [FLINK-40833] Fix accumulator corruption in NonTimeRowsUnboundedPrecedingFunction [flink] via GitHub
• 2026/10/07 Re: [PR] [FLINK-40923][table] Do not simplify reflexive comparisons on FLOAT/DOUBLE [flink] via GitHub
• 2026/10/07 Re: [PR] [FLINK-40916][runtime] Optionally skip eager initialization of checkpoint base locations [flink] via GitHub
• 2026/10/07 Re: [PR] [FLINK-40172][table-runtime] Support processing-time early fire on a row-time interval join [flink] via GitHub
• 2026/10/07 [PR] [api][plan] Abstain on runtime non-candidate model selections [flink-agents] via GitHub
• 2026/10/07 Re: [PR] [FLINK-40896][table]Deduplicate keep first implementation [flink] via GitHub
• 2026/10/07 [jira] [Updated] (FLINK-40944) CPU limit-factor inflates the JVM's availableProcessors() to the CPU limit ASF GitHub Bot (Jira)
• 2026/10/07 [PR] [FLINK-40944][operator] Pin -XX:ActiveProcessorCount to the CPU request when a CPU limit factor is set [flink-kubernetes-operator] via GitHub
• 2026/10/07 Re: [PR] [api][plan][runtime][python] Support registering an Agent as an in-process internal sub-agent [flink-agents] via GitHub
• 2026/10/07 Re: [PR] [FLINK-40910][table] Reject VARIANT where a query needs equality or ordering [flink] via GitHub
• 2026/10/07 Re: [PR] [FLINK-40910][table] Reject VARIANT where a query needs equality or ordering [flink] via GitHub
• 2026/10/07 [jira] [Commented] (FLINK-40937) UPDATE fails with IndexOutOfBoundsException when a SET value's type doesn't match the column Sergey Nuyanzin (Jira)
• 2026/10/07 [jira] [Created] (FLINK-40936) Built-in functions compare VARIANT array elements and map keys by their binary encoding Ramin Gharib (Jira)
• 2026/10/07 [jira] [Updated] (FLINK-40937) UPDATE fails with IndexOutOfBoundsException when a SET value's type doesn't match the column ASF GitHub Bot (Jira)
• 2026/10/07 [PR] [FLINK-38569][table-planner] Don't record a ReadingMetadata ability without metadata keys [flink] via GitHub
• 2026/10/07 Re: [PR] [integration][java][python] Send user images and documents to Anthropic [flink-agents] via GitHub
• 2026/10/07 Re: [PR] [FLINK-38569][table-planner] Don't record a ReadingMetadata ability without metadata keys [flink] via GitHub
• 2026/10/07 Re: [PR] [FLINK-40844][table] Only EXPR$0 when a PTF's whole output is empty [flink] via GitHub
• 2026/10/07 Re: [PR] [FLINK-40941][table] Add warmup for `Janino` [flink] via GitHub
• 2026/10/07 Re: [PR] [FLINK-40943][filesystems] Restore FileSink state written with flink-s3-fs-hadoop in flink-s3-fs-native [flink] via GitHub

• Earlier messages
• Later messages