issues
Thread
Date
Earlier messages
Later messages
Messages by Date
2026/10/08
Re: [PR] [FLINK-40737][table] Keep non-time OVER data views inside the accumulator [flink]
via GitHub
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-40902][table] Support LATERAL SNAPSHOT join without an equi-key [flink]
via GitHub
2026/10/08
[I] [Bug][java] Missing Log4j dependencies in IDE support [flink-agents]
via GitHub
2026/10/08
Re: [PR] [FLINK-40953][s3] Store the native S3 recoverable writer tail under the target directory [flink]
via GitHub
2026/10/08
[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/08
[jira] [Commented] (FLINK-40957) MongoDB CDC encodes spaces as '+' instead of '%20' in credentials
Yahya Kisana (Jira)
2026/10/08
[jira] [Updated] (FLINK-27963) FlinkRuntimeException in KafkaSink causes a Flink job to hang
Martijn Visser (Jira)
2026/10/08
[jira] [Commented] (FLINK-28440) EventTimeWindowCheckpointingITCase failed with restore
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
[PR] [api][runtime][java][python] Add non-durable async execution [flink-agents]
via GitHub
2026/10/08
Re: [PR] [FLINK-38907][postgres] Debezium publication filtering data lost [flink-cdc]
via GitHub
2026/10/08
[jira] [Updated] (FLINK-40958) VARIANT might fail with StackOverflow
Sergey Nuyanzin (Jira)
2026/10/08
Re: [PR] [FLINK-40940][connector-http] Decide lookup row emission independently of applyReadableMetadata [flink-connector-http]
via GitHub
2026/10/08
[jira] [Commented] (FLINK-40789) RescaleTimelineITCase.testRecordRescaleForNewAvailableResource records three rescales instead of two
Martijn Visser (Jira)
2026/10/08
[jira] [Commented] (FLINK-34405) RightOuterJoinTaskTest#testCancelOuterJoinTaskWhileSort2 fails due to an interruption of the RightOuterJoinDriver#prepare method
Martijn Visser (Jira)
2026/10/08
Re: [PR] [FLINK-40608][python] Extract Dataframe type inference mechanism to shared component, add not null by default [flink]
via GitHub
2026/10/08
[jira] [Assigned] (FLINK-39214) Support TIME type precision beyond milliseconds (precision > 3)
Ramin Gharib (Jira)
2026/10/08
[jira] [Updated] (FLINK-34405) RightOuterJoinTaskTest#testCancelOuterJoinTaskWhileSort2 fails due to an interruption of the RightOuterJoinDriver#prepare method
Martijn Visser (Jira)
2026/10/08
[jira] [Commented] (FLINK-39620) Cumulative window re-emits old windows after recovery due to stale InternalTimerService.currentWatermark in GlobalAggCombiner
Chanhae Oh (Jira)
2026/10/08
[jira] [Assigned] (FLINK-40856) Support zip-style multi-column explode in DataFrame API
Dian Fu (Jira)
2026/10/08
[jira] [Updated] (FLINK-40193) Add join_lateral support to DataFrame API
ASF GitHub Bot (Jira)
2026/10/08
[PR] [FLINK-40193][python] Add join_lateral support to the DataFrame API [flink]
via GitHub
2026/10/08
[PR] [FLINK-40436][python] Add UDAF support to the DataFrame API [flink]
via GitHub
2026/10/08
Re: [PR] [FLINK-40885][table] Support LATERAL SNAPSHOT join in the Table API [flink]
via GitHub
2026/10/08
[jira] [Updated] (FLINK-40958) VARIANT might fail with StackOverflow
ASF GitHub Bot (Jira)
2026/10/08
[PR] [FLINK-40958][core] Do not use recurcion in `VARIANT` `toJson` [flink]
via GitHub
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] [Updated] (FLINK-40958) VARIANT might fail with StackOverflow
Sergey Nuyanzin (Jira)
2026/10/08
[jira] [Updated] (FLINK-40958) VARIANT might fail with StackOverflow
Sergey Nuyanzin (Jira)
2026/10/08
[jira] [Commented] (FLINK-40856) Support zip-style multi-column explode in DataFrame API
Dian Fu (Jira)
2026/10/08
[jira] [Created] (FLINK-40958) VARIANT might fail with StackOverflow
Sergey Nuyanzin (Jira)
2026/10/08
[PR] Fix MongoDB credential encoding for spaces [flink-cdc]
via GitHub
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: [I] [Tech Debt][API][ReActAgent] Support Skills directly in Java and Python constructors [flink-agents]
via GitHub
2026/10/08
[jira] [Commented] (FLINK-40950) EarlyFireJoinHintTest.testEarlyFireProcTimeOnRowTimeJoin fails with unexpected output
Chanhae Oh (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
[jira] [Commented] (FLINK-40940) HTTP lookup source drops the row for a failed call with continue-on-error unless the planner calls applyReadableMetadata
Arvid Heise (Jira)
2026/10/08
Re: [PR] [FLINK-40953][s3] Store the native S3 recoverable writer tail under the target directory [flink]
via GitHub
2026/10/08
Re: [PR] [FLINK-40737][table] Keep non-time OVER data views inside the accumulator [flink]
via GitHub
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-28985) support create table like view
Chanhae Oh (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-40885][table] Support LATERAL SNAPSHOT join in the Table API [flink]
via GitHub
2026/10/08
Re: [PR] [FLINK-40953][s3] Store the native S3 recoverable writer tail under the target directory [flink]
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
Re: [PR] [FLINK-40940][connector-http] Decide lookup row emission independently of applyReadableMetadata [flink-connector-http]
via GitHub
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-40957) MongoDB CDC encodes spaces as '+' instead of '%20' in credentials
luana (Jira)
2026/10/08
Re: [PR] [FLINK-40901][table] Fixed the codegen bug w jsonType/Length [flink]
via GitHub
2026/10/08
[jira] [Commented] (FLINK-40571) ProcessTableFunctionSemanticTests[process-stateful-multi-input-with-timeout] is flaky on master
Purushottam Sinha (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-40952][state/forst] Close the DBOptions copy of temporary restore DBs [flink]
via GitHub
2026/10/08
Re: [PR] [FLINK-40436][python] Add UDAF support to the DataFrame API [flink]
via GitHub
2026/10/08
[jira] [Updated] (FLINK-40436) Add UDAF support to DataFrame API
ASF GitHub Bot (Jira)
2026/10/08
[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
sepuri sai krishna (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
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-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
Earlier messages
Later messages