issues  

Messages by Date

• 2026/10/27 Re: [PR] [FLINK-40123][e2e] heck_logs_for_exceptions false-positives on S3A stream_write_exceptions counter, flaking test_kubernetes_materialized_table.sh [flink] via GitHub
• 2026/10/27 Re: [PR] [hotfix][ci] Run the GHA nightly on release-2.3 again [flink] via GitHub
• 2026/10/27 Re: [PR] [BP-Dev-2.4][FLINK-41061] Reduce adaptive benchmark sleep frequency [flink-benchmarks] via GitHub
• 2026/10/27 [jira] [Created] (FLINK-41244) PTF clearAllTimers() deletes unnamed timers across all keys and corrupts the key context Timo Walther (Jira)
• 2026/10/27 [jira] [Resolved] (FLINK-33186) CheckpointAfterAllTasksFinishedITCase.testRestoreAfterSomeTasksFinished fails on AZP Martijn Visser (Jira)
• 2026/10/27 [jira] [Comment Edited] (FLINK-33186) CheckpointAfterAllTasksFinishedITCase.testRestoreAfterSomeTasksFinished fails on AZP Martijn Visser (Jira)
• 2026/10/27 [PR] [FLINK-38199][benchmark] Add SinkUpsertMaterializerBenchmark for V1 and V2 [flink-benchmarks] via GitHub
• 2026/10/27 Re: [PR] [FLINK-33186][tests][BP-2.3] Addressing CheckpointAfterAllTasksFinishedITCase CI flakiness [flink] via GitHub
• 2026/10/27 [jira] [Commented] (FLINK-41048) MiniClusterJobEntryPointITCase.restartResumesJobFromLatestCheckpoint fails to bind the REST port on restart Dale Lane (Jira)
• 2026/10/27 Re: [PR] [FLINK-41203][docs] Help users pick between the Kafka SQL connectors [flink-connector-kafka] via GitHub
• 2026/10/27 [PR] [hotfix][ci] Run the GHA nightly on release-2.3 again [flink] via GitHub
• 2026/10/27 Re: [PR] [FLINK-41217][table] VALUES source emits its rows again when a streaming job restores from a checkpoint taken before the source exits [flink] via GitHub
• 2026/10/27 Re: [PR] [FLINK-41217][table] VALUES source emits its rows again when a streaming job restores from a checkpoint taken before the source exits [flink] via GitHub
• 2026/10/27 [jira] [Created] (FLINK-41240) Set the start mode of a materialized table declaration Timo Theusner (Jira)
• 2026/10/27 [jira] [Updated] (FLINK-38534) Fix flaky LocalRecoveryTest by waiting for tasks to reach RUNNING state Martijn Visser (Jira)
• 2026/10/27 [jira] [Updated] (FLINK-34447) ActiveResourceManagerTest#testWorkerRegistrationTimeoutNotCountingAllocationTime still fails on slow machines Martijn Visser (Jira)
• 2026/10/27 Re: [PR] [FLINK-41217][table] VALUES source emits its rows again when a streaming job restores from a checkpoint taken before the source exits [flink] via GitHub
• 2026/10/27 [jira] [Updated] (FLINK-38534) Fix flaky LocalRecoveryTest by waiting for tasks to reach RUNNING state Martijn Visser (Jira)
• 2026/10/27 [jira] [Updated] (FLINK-40958) VARIANT might fail with StackOverflow Martijn Visser (Jira)
• 2026/10/27 [jira] [Updated] (FLINK-40958) VARIANT might fail with StackOverflow Martijn Visser (Jira)
• 2026/10/27 [jira] [Updated] (FLINK-41248) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fails with OutOfMemoryError: Direct buffer memory in the Netty server Martijn Visser (Jira)
• 2026/10/27 [jira] [Updated] (FLINK-40789) RescaleTimelineITCase.testRecordRescaleForNewAvailableResource records three rescales instead of two Martijn Visser (Jira)
• 2026/10/27 Re: [PR] [FLINK-41217][table] VALUES source emits its rows again when a streaming job restores from a checkpoint taken before the source exits [flink] via GitHub
• 2026/10/27 [jira] [Commented] (FLINK-30644) ChangelogCompatibilityITCase.testRestore fails due to CheckpointCoordinator being shutdown Martijn Visser (Jira)
• 2026/10/27 [jira] [Commented] (FLINK-39954) SinkV2ITCase over-asserts commit multiplicity under unaligned checkpoints Martijn Visser (Jira)
• 2026/10/27 Re: [PR] [FLINK-41217][table] VALUES source emits its rows again when a streaming job restores from a checkpoint taken before the source exits [flink] via GitHub
• 2026/10/27 [jira] [Commented] (FLINK-40958) VARIANT might fail with StackOverflow Martijn Visser (Jira)
• 2026/10/27 [jira] [Commented] (FLINK-40958) VARIANT might fail with StackOverflow Martijn Visser (Jira)
• 2026/10/27 [jira] [Commented] (FLINK-34224) ChangelogStorageMetricsTest.testAttemptsPerUpload(ChangelogStorageMetricsTest timed out Martijn Visser (Jira)
• 2026/10/27 [jira] [Commented] (FLINK-40804) UnalignedCheckpointRescaleWithMixedExchangesITCase.testRescaleFromUnalignedCheckpoint fails with "Exceeded checkpoint tolerable failure threshold" Martijn Visser (Jira)
• 2026/10/27 [jira] [Commented] (FLINK-41045) 'Running Kerberized YARN application on Docker test (custom fs plugin)' fails with NoResourceAvailableException because two of three TaskManager containers never register Martijn Visser (Jira)
• 2026/10/27 [jira] [Commented] (FLINK-40069) OpenTelemetryMetricReporterProtocolTest fails with "No content to map due to end-of-input" due to OTel collector readiness race Martijn Visser (Jira)
• 2026/10/27 [jira] [Commented] (FLINK-26644) python StreamExecutionEnvironmentTests.test_generate_stream_graph_with_dependencies failed on azure Martijn Visser (Jira)
• 2026/10/27 [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/27 [jira] [Commented] (FLINK-41048) MiniClusterJobEntryPointITCase.restartResumesJobFromLatestCheckpoint fails to bind the REST port on restart Martijn Visser (Jira)
• 2026/10/27 [jira] [Updated] (FLINK-40123) heck_logs_for_exceptions false-positives on S3A stream_write_exceptions counter, flaking test_kubernetes_materialized_table.sh Martijn Visser (Jira)
• 2026/10/27 [jira] [Updated] (FLINK-40123) heck_logs_for_exceptions false-positives on S3A stream_write_exceptions counter, flaking test_kubernetes_materialized_table.sh Martijn Visser (Jira)
• 2026/10/27 [jira] [Commented] (FLINK-40123) heck_logs_for_exceptions false-positives on S3A stream_write_exceptions counter, flaking test_kubernetes_materialized_table.sh Martijn Visser (Jira)
• 2026/10/27 [jira] [Commented] (FLINK-40789) RescaleTimelineITCase.testRecordRescaleForNewAvailableResource records three rescales instead of two Martijn Visser (Jira)
• 2026/10/27 [jira] [Commented] (FLINK-34523) Some jar couldn't be downloaded from google-maven-central Martijn Visser (Jira)
• 2026/10/27 [jira] [Commented] (FLINK-38534) Fix flaky LocalRecoveryTest by waiting for tasks to reach RUNNING state Martijn Visser (Jira)
• 2026/10/27 [jira] [Created] (FLINK-41248) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fails with OutOfMemoryError: Direct buffer memory in the Netty server Martijn Visser (Jira)
• 2026/10/27 [jira] [Commented] (FLINK-34447) ActiveResourceManagerTest#testWorkerRegistrationTimeoutNotCountingAllocationTime still fails on slow machines Martijn Visser (Jira)
• 2026/10/27 [jira] [Commented] (FLINK-40793) DefaultSchedulerTest is unstable across many test methods Martijn Visser (Jira)
• 2026/10/27 [jira] [Created] (FLINK-41247) AbstractServerTest.testPortRangeSuccess sees an open server connection after the servers are closed Martijn Visser (Jira)
• 2026/10/27 Re: [PR] [FLINK-41217][table] VALUES source emits its rows again when a streaming job restores from a checkpoint taken before the source exits [flink] via GitHub
• 2026/10/27 [jira] [Updated] (FLINK-41247) AbstractServerTest.testPortRangeSuccess sees an open server connection after the servers are closed Martijn Visser (Jira)
• 2026/10/27 [jira] [Updated] (FLINK-41245) PyFlink mypy check fails on release-2.3: create_arrow_schema has no allow_nested parameter Martijn Visser (Jira)
• 2026/10/27 Re: [PR] [FLINK-41217][table] VALUES source emits its rows again when a streaming job restores from a checkpoint taken before the source exits [flink] via GitHub
• 2026/10/27 [jira] [Created] (FLINK-41246) PyFlink nested row tests from FLINK-41199 fail on release-1.20 Martijn Visser (Jira)
• 2026/10/27 [jira] [Updated] (FLINK-41246) PyFlink nested row tests from FLINK-41199 fail on release-1.20 Martijn Visser (Jira)
• 2026/10/27 [jira] [Updated] (FLINK-41245) PyFlink mypy check fails on release-2.3: create_arrow_schema has no allow_nested parameter Martijn Visser (Jira)
• 2026/10/27 [jira] [Created] (FLINK-41245) PyFlink mypy check fails on release-2.3: create_arrow_schema has no allow_nested parameter Martijn Visser (Jira)
• 2026/10/27 Re: [PR] [FLINK-41217][table] VALUES source emits its rows again when a streaming job restores from a checkpoint taken before the source exits [flink] via GitHub
• 2026/10/27 Re: [PR] [BP-5.0][FLINK-41203][docs] Help users pick between the Kafka SQL connectors [flink-connector-kafka] via GitHub
• 2026/10/27 Re: [PR] [FLINK-41203][docs] Help users pick between the Kafka SQL connectors [flink-connector-kafka] via GitHub
• 2026/10/27 Re: [PR] [FLINK-41228][python] Fix thread-mode conversion of arrays, lists and maps [flink] via GitHub
• 2026/10/27 Re: [PR] [FLINK-41202][docs] Make connector integrations easier to find from the Flink docs [flink] via GitHub
• 2026/10/27 [jira] [Assigned] (FLINK-41241) Remember the field index in VARIANT key lookups Ramin Gharib (Jira)
• 2026/10/27 Re: [PR] [FLINK-41217][table] VALUES source emits its rows again when a streaming job restores from a checkpoint taken before the source exits [flink] via GitHub
• 2026/10/27 Re: [PR] [FLINK-41217][table] VALUES source emits its rows again when a streaming job restores from a checkpoint taken before the source exits [flink] via GitHub
• 2026/10/27 [PR] [api][plan][java] Add a decision-model routing strategy for MODEL_ROUTER [flink-agents] via GitHub
• 2026/10/27 [jira] [Updated] (FLINK-40733) Trino tests are disabled, so the Trino dialect has no test coverage ASF GitHub Bot (Jira)
• 2026/10/27 [PR] [FLINK-40733][connector-jdbc] Re-enable the Trino tests [flink-connector-jdbc] via GitHub
• 2026/10/27 [jira] [Closed] (FLINK-39098) Fix connector CI failures caused by testcontainers using too old Docker API Ferenc Csaky (Jira)
• 2026/10/27 [jira] [Comment Edited] (FLINK-39098) Fix connector CI failures caused by testcontainers using too old Docker API Ferenc Csaky (Jira)
• 2026/10/27 Re: [PR] [FLINK-39098] Bump testcontainers to 1.21.4 for Docker API compatibility [flink-connector-aws] via GitHub
• 2026/10/27 Re: [PR] [FLINK-39098] Bump testcontainers to 1.21.4 for Docker API compatibility [flink-connector-aws] via GitHub
• 2026/10/27 Re: [PR] [FLINK-39098] Bump `testcontainers` to 1.21.4 for Docker API compatibility [flink-connector-aws] via GitHub
• 2026/10/27 Re: [PR] [FLINK-40948][table] Maintain window properties for different joins [flink] via GitHub
• 2026/10/27 [jira] [Commented] (FLINK-41222) Autoscaler reports an error when a ConfigMap write is applied but the client's retry conflicts Alex Kukhar (Jira)
• 2026/10/27 [jira] [Assigned] (FLINK-41222) Autoscaler reports an error when a ConfigMap write is applied but the client's retry conflicts Gyula Fora (Jira)
• 2026/10/27 Re: [PR] [BP-2.4][FLINK-41180][core] Sort VARIANT object fields by UTF-8 bytes [flink] via GitHub
• 2026/10/27 Re: [PR] [FLINK-41241][core] Remember the field index in VARIANT key lookups [flink] via GitHub
• 2026/10/27 [jira] [Resolved] (FLINK-41230) Declare flink-connector-base as provided in flink-connector-jdbc Martijn Visser (Jira)
• 2026/10/27 [jira] [Assigned] (FLINK-41047) SqsSinkWriterTest.getNumRecordsOutErrorsCounterRecordsCorrectNumberOfFailures gets a connection acquire timeout instead of Connection refused Ferenc Csaky (Jira)
• 2026/10/27 Re: [PR] [FLINK-40924][table-planner] Enforce require-on-conflict under upsert-materialize FORCE [flink] via GitHub
• 2026/10/27 Re: [PR] [FLINK-41228][python] Fix thread-mode conversion of arrays, lists and maps [flink] via GitHub
• 2026/10/27 Re: [PR] [BP-2.4][FLINK-40924][table-planner] Enforce require-on-conflict under upsert-materialize FORCE [flink] via GitHub
• 2026/10/27 Re: [PR] [FLINK-40896][table]Deduplicate keep first implementation [flink] via GitHub
• 2026/10/27 Re: [PR] [FLINK-40924][table-planner] Enforce require-on-conflict under upsert-materialize FORCE [flink] via GitHub
• 2026/10/27 [PR] [BP-2.4][FLINK-40924][table-planner] Enforce require-on-conflict under upsert-materialize FORCE [flink] via GitHub
• 2026/10/27 [jira] [Created] (FLINK-41243) VARIANT field access with a non-literal key fails in code generation Ramin Gharib (Jira)
• 2026/10/27 [jira] [Assigned] (FLINK-41243) VARIANT field access with a non-literal key fails in code generation Ramin Gharib (Jira)
• 2026/10/27 Re: [PR] [docs] Standardize Alibaba Cloud Model Studio naming [flink-agents] via GitHub
• 2026/10/27 [jira] [Commented] (FLINK-41242) status.error reports every exception of a failed job as `org.apache.flink.util.SerializedThrowable` Santwana Verma (Jira)
• 2026/10/27 Re: [PR] [FLINK-40896][table]Deduplicate keep first implementation [flink] via GitHub
• 2026/10/27 [PR] [FLINK-38562][python] Support async functions in thread mode [flink] via GitHub
• 2026/10/27 Re: [PR] [FLINK-38262][table] Add DROP CONNECTION operation [flink] via GitHub
• 2026/10/27 Re: [PR] [FLINK-41231][build] Publish SBOM artifacts [flink-connector-jdbc] via GitHub
• 2026/10/27 Re: [PR] [FLINK-41241][core] Remember the field index in VARIANT key lookups [flink] via GitHub
• 2026/10/27 [jira] [Closed] (FLINK-41195) Avoid flushing Python bundles during task cancellation Dian Fu (Jira)
• 2026/10/27 [jira] [Updated] (FLINK-40924) table.exec.sink.upsert-materialize=FORCE silently bypasses the require-on-conflict check Yuepeng Pan (Jira)
• 2026/10/27 Re: [PR] [FLINK-40924][table-planner] Enforce require-on-conflict under upsert-materialize FORCE [flink] via GitHub
• 2026/10/27 [jira] [Updated] (FLINK-41241) Remember the field index in VARIANT key lookups ASF GitHub Bot (Jira)
• 2026/10/27 Re: [PR] [hotfix][python] Use correct package for `ByteString` [flink] via GitHub
• 2026/10/27 [jira] [Updated] (FLINK-40924) table.exec.sink.upsert-materialize=FORCE silently bypasses the require-on-conflict check Yuepeng Pan (Jira)
• 2026/10/27 [jira] [Updated] (FLINK-41061) Daily benchmark keeps failing because of excessive runtime of the adaptive partition benchmark Yuepeng Pan (Jira)
• 2026/10/27 [jira] [Commented] (FLINK-41061) Daily benchmark keeps failing because of excessive runtime of the adaptive partition benchmark Yuepeng Pan (Jira)
• 2026/10/27 [jira] [Assigned] (FLINK-41061) Daily benchmark keeps failing because of excessive runtime of the adaptive partition benchmark Yuepeng Pan (Jira)
• 2026/10/27 [jira] [Commented] (FLINK-40924) table.exec.sink.upsert-materialize=FORCE silently bypasses the require-on-conflict check Yuepeng Pan (Jira)
• 2026/10/27 [jira] [Assigned] (FLINK-41242) status.error reports every exception of a failed job as `org.apache.flink.util.SerializedThrowable` Robert Metzger (Jira)
• 2026/10/27 [jira] [Created] (FLINK-41242) status.error reports every exception of a failed job as `org.apache.flink.util.SerializedThrowable` Santwana Verma (Jira)
• 2026/10/27 [jira] [Updated] (FLINK-41242) status.error reports every exception of a failed job as `org.apache.flink.util.SerializedThrowable` Santwana Verma (Jira)
• 2026/10/27 [jira] [Updated] (FLINK-41242) status.error reports every exception of a failed job as `org.apache.flink.util.SerializedThrowable` Santwana Verma (Jira)
• 2026/10/27 Re: [PR] [FLINK-41061] Reduce sleep frequency of adaptive partition selection benchmark [flink-benchmarks] via GitHub
• 2026/10/27 Re: [PR] [FLINK-41195][python] Skip bundle completion during cancellation [flink] via GitHub
• 2026/10/27 Re: [PR] [integration][java] Send user images and documents through the OpenAI Responses API [flink-agents] via GitHub
• 2026/10/27 Re: [PR] [FLINK-41217][table] VALUES source emits its rows again when a streaming job restores from a checkpoint taken before the source exits [flink] via GitHub
• 2026/10/27 [jira] [Created] (FLINK-41241) Remember the field index in VARIANT key lookups Ramin Gharib (Jira)
• 2026/10/27 Re: [PR] [FLINK-40896][table]Deduplicate keep first implementation [flink] via GitHub
• 2026/10/27 Re: [PR] [FLINK-XXXXX][core] Remember the field index in VARIANT key lookups [flink] via GitHub
• 2026/10/27 [PR] [FLINK-XXXXX][core] Remember the field index in VARIANT key lookups [flink] via GitHub
• 2026/10/27 Re: [PR] [FLINK-40938][Connectors/DynamoDB] Support AT_TIMESTAMP initial position in DynamoDB Streams source [flink-connector-aws] via GitHub
• 2026/10/27 [PR] [hotfix][Connectors/Kafka] Remove orphaned ArchUnit violation stores [flink-connector-kafka] via GitHub
• 2026/10/27 Re: [PR] [FLINK-40609][python] Infer ROW types from dataclass, NamedTuple and tuple type hints [flink] via GitHub
• 2026/10/27 [PR] [docs] Standardize Alibaba Cloud Model Studio naming [flink-agents] via GitHub
• 2026/10/27 Re: [PR] [FLINK-41208][connector-jdbc] Only accept TYPE_SCROLL_INSENSITIVE for exactly-once JdbcSource [flink-connector-jdbc] via GitHub
• 2026/10/27 Re: [PR] Announce Flink Agents 0.4.0 [flink-web] via GitHub
• 2026/10/27 Re: [PR] [FLINK-41193][checkpointing] Disable checkpointing during recovery when aligned-checkpoint-timeout > 0 [flink] via GitHub
• 2026/10/27 [jira] [Resolved] (FLINK-41193) Disable checkpointing during recovery when aligned-checkpoint-timeout > 0 Rui Fan (Jira)
• 2026/10/27 [jira] [Comment Edited] (FLINK-41193) Disable checkpointing during recovery when aligned-checkpoint-timeout > 0 Rui Fan (Jira)
• 2026/10/27 Re: [PR] [FLINK-41230][build] Declare flink-connector-base as provided [flink-connector-jdbc] via GitHub
• 2026/10/27 Re: [PR] [FLINK-38562][python] Support async functions in thread mode [flink] via GitHub
• 2026/10/27 Re: [PR] [FLINK-41195][python] Skip bundle completion during cancellation [flink] via GitHub
• 2026/10/27 Re: [PR] [FLINK-38262][table] show connections operation [flink] via GitHub
• 2026/10/27 [jira] [Updated] (FLINK-38562) Support thread mode of async function in Python DataStream API ASF GitHub Bot (Jira)
• 2026/10/27 Re: [PR] [FLINK-41231][build] Publish SBOM artifacts [flink-connector-jdbc] via GitHub
• 2026/10/27 [jira] [Created] (FLINK-41239) Look up an existing materialized table with fromMaterializedTable Timo Theusner (Jira)
• 2026/10/27 [jira] [Created] (FLINK-41237) Add MaterializedTableDescriptor for full materialized table declarations Timo Theusner (Jira)
• 2026/10/27 [jira] [Created] (FLINK-41238) Add CreateMode to refuse an existing object at the declared path Timo Theusner (Jira)
• 2026/10/27 [jira] [Created] (FLINK-41236) Recover materialized tables that have no controllable refresh job Timo Theusner (Jira)
• 2026/10/27 Re: [PR] [FLINK-40273][docs] Update JDBC documentation for the 4.x module split and APIs [flink-connector-jdbc] via GitHub
• 2026/10/27 Re: [PR] [integration][java] Send user images, audio, video and documents to Gemini [flink-agents] via GitHub
• 2026/10/27 Re: [PR] [FLINK-XXXXX] Restore interrupt status in InterruptedException catch blocks [flink] via GitHub
• 2026/10/27 [jira] [Resolved] (FLINK-41032) PyFlink Table.to_pandas() loses column dtypes when the result is empty Dian Fu (Jira)
• 2026/10/27 [PR] [BP-1.20][FLINK-41049][ci] Make pre-downloaded Maven usable by the only-script Maven wrapper [flink] via GitHub
• 2026/10/27 [jira] [Updated] (FLINK-41083) Add quickstart examples and best practice for Flink CDC docs ASF GitHub Bot (Jira)
• 2026/10/27 Re: [PR] [FLINK-41194][Stream] Use PulsarAdmin to check transaction state [flink-connector-pulsar] via GitHub
• 2026/10/27 Re: [D] Planning Flink Agents 1.0 - Brainstorming [flink-agents] via GitHub
• 2026/10/27 Re: [PR] [FLINK-40924][table-planner] Enforce require-on-conflict under upsert-materialize FORCE [flink] via GitHub
• 2026/10/27 [jira] [Commented] (FLINK-40931) ForSt restore with object-store in restore mode fails when scaling in Yuepeng Pan (Jira)
• 2026/10/27 [jira] [Assigned] (FLINK-41199) PyFlink result collection fails for NULL values inside nested rows and collections Dian Fu (Jira)
• 2026/10/27 Re: [PR] [FLINK-41196][python] Preserve TIMESTAMP_LTZ instants in Python conversions [flink] via GitHub
• 2026/10/27 [jira] [Assigned] (FLINK-41032) PyFlink Table.to_pandas() loses column dtypes when the result is empty Dian Fu (Jira)
• 2026/10/27 Re: [PR] [hotfix][python] Use correct package for `ByteString` [flink] via GitHub
• 2026/10/27 Re: [PR] [FLINK-40931][state/forst] Track renamed directories in `ForStFileSystemTrackingCreatedDirDecorator` [flink] via GitHub
• 2026/10/27 Re: [PR] [FLINK-41032][python] Preserve column dtypes when converting empty tables to pandas [flink] via GitHub
• 2026/10/27 [PR] [FLINK-41083][docs] Add YAML pipeline examples and best practices [flink-cdc] via GitHub
• 2026/10/27 [jira] [Comment Edited] (FLINK-40123) heck_logs_for_exceptions false-positives on S3A stream_write_exceptions counter, flaking test_kubernetes_materialized_table.sh Mateusz Barnacki (Jira)
• 2026/10/27 [jira] [Updated] (FLINK-41226) Benchmark StreamNetworkThroughputBenchmarkExecutor.networkThroughput failed Yuepeng Pan (Jira)
• 2026/10/27 Re: [PR] [FLINK-41061] Reduce sleep frequency of adaptive partition selection benchmark [flink-benchmarks] via GitHub
• 2026/10/27 Re: [PR] [FLINK-40527] Update flink-shaded to 22.0 [flink-benchmarks] via GitHub
• 2026/10/27 Re: [PR] [FLINK-40527] Update flink-shaded to 22.0 [flink-benchmarks] via GitHub
• 2026/10/27 Re: [PR] [hotfix][python] Use correct package for `ByteString` [flink] via GitHub
• 2026/10/27 Re: [PR] [BP-1.20][FLINK-41049][ci] Make pre-downloaded Maven usable by the only-script Maven wrapper [flink] via GitHub
• 2026/10/27 Re: [PR] [hotfix][python] Use correct package for `ByteString` [flink] via GitHub
• 2026/10/27 [PR] [hotfix][python] Use correct package for `ByteString` [flink] via GitHub
• 2026/10/27 [jira] [Updated] (FLINK-41228) Thread-mode PyFlink DataStream converters mishandle rows in arrays, lists and maps ASF GitHub Bot (Jira)
• 2026/10/27 Re: [PR] [BP-2.2][FLINK-41049][ci] Make pre-downloaded Maven usable by the only-script Maven wrapper [flink] via GitHub
• 2026/10/26 [jira] [Assigned] (FLINK-41145) Release Testing Instructions: FLIP-591: Introducing Python DataFrame API in PyFlink Yuepeng Pan (Jira)
• 2026/10/26 [PR] [FLINK-41228][python] Fix thread-mode conversion of arrays, lists and maps [flink] via GitHub
• 2026/10/26 [PR] [FLINK-40931][state/forst] Track renamed directories in `ForStFileSystemTrackingCreatedDirDecorator` [flink] via GitHub
• 2026/10/26 [jira] [Updated] (FLINK-40954) Force delete pods stuck Terminating on cluster resource cleanup timeout ASF GitHub Bot (Jira)
• 2026/10/26 [PR] [FLINK-40954] Force delete pods stuck Terminating on cluster resourcecleanup timeout [flink-kubernetes-operator] via GitHub
• 2026/10/26 [jira] [Assigned] (FLINK-41228) Thread-mode PyFlink DataStream converters mishandle rows in arrays, lists and maps Dian Fu (Jira)
• 2026/10/26 [PR] [BP-2.2][FLINK-41049][ci] Make pre-downloaded Maven usable by the only-script Maven wrapper [flink] via GitHub
• 2026/10/26 Re: [PR] [FLINK-39875][table-gateway] Restore thread interrupt status in ResultStore [flink] via GitHub
• 2026/10/26 Re: [PR] [kubernetes] Graceful TaskManager termination + fix wrong-signal TODO in ResourceManager [flink] via GitHub
• 2026/10/26 Re: [PR] [FLINK-39875][table-gateway] Restore thread interrupt status in ResultStore [flink] via GitHub
• 2026/10/26 Re: [PR] [FLINK-38418][python] Support pickling Instants when collecting TIMESTAMP_LTZ types in PyFlink [flink] via GitHub
• 2026/10/26 Re: [PR] [FLINK-41049][ci] Make pre-downloaded Maven usable by the only-script Maven wrapper [flink] via GitHub
• 2026/10/26 [PR] [FLINK-41049][ci] Make pre-downloaded Maven usable by the only-script Maven wrapper [flink] via GitHub
• 2026/10/26 Re: [PR] [FLINK-41217][table] VALUES source emits its rows again when a streaming job restores from a checkpoint taken before the source exits [flink] via GitHub
• 2026/10/26 [PR] [FLINK-41086][table] Return NULL from `JSON_LENGTH` and `JSON_TYPE` when a JSON path function fails [flink] via GitHub
• 2026/10/26 Re: [PR] [FLINK-41228][python] Fix thread-mode conversion of arrays, lists and maps [flink] via GitHub
• 2026/10/26 Re: [PR] [FLINK-41086][table] Return NULL from `JSON_LENGTH` and `JSON_TYPE` when a JSON path function fails [flink] via GitHub
• 2026/10/26 [jira] [Updated] (FLINK-41086) JSON_LENGTH and JSON_TYPE fail the job when a JSON path function throws ASF GitHub Bot (Jira)
• 2026/10/26 [PR] [BP-Dev-2.4][FLINK-41061] Reduce adaptive benchmark sleep frequency [flink-benchmarks] via GitHub
• 2026/10/26 Re: [PR] [FLINK-41086][table] Return NULL from `JSON_LENGTH` and `JSON_TYPE` when a JSON path function fails [flink] via GitHub
• 2026/10/26 Re: [PR] [FLINK-40931][state/forst] Track renamed directories in `ForStFileSystemTrackingCreatedDirDecorator` [flink] via GitHub
• 2026/10/26 [jira] [Resolved] (FLINK-41226) Benchmark StreamNetworkThroughputBenchmarkExecutor.networkThroughput failed Yuepeng Pan (Jira)
• 2026/10/26 [jira] [Commented] (FLINK-41226) Benchmark StreamNetworkThroughputBenchmarkExecutor.networkThroughput failed Yuepeng Pan (Jira)
• 2026/10/26 Re: [PR] [BP-2.4][FLINK-41226][build] Bump tcnative to 2.0.81 and run CI on Ubuntu 26.04 [flink-benchmarks] via GitHub
• 2026/10/26 Re: [PR] [FLINK-41226][build] Bump tcnative to 2.0.81 and run CI on Ubuntu 26.04 [flink-benchmarks] via GitHub
• 2026/10/26 [jira] [Assigned] (FLINK-41147) Release Testing Instructions: FLIP-583: Expose JobInfo on Source contexts Yuepeng Pan (Jira)
• 2026/10/26 [jira] [Commented] (FLINK-41145) Release Testing Instructions: FLIP-591: Introducing Python DataFrame API in PyFlink Dian Fu (Jira)
• 2026/10/26 Re: [PR] Flink 41061 drafted [flink-benchmarks] via GitHub
• 2026/10/26 [jira] [Resolved] (FLINK-41196) PyFlink pandas conversions and regular Python UDFs change TIMESTAMP_LTZ instants in non-UTC session time zones Dian Fu (Jira)
• 2026/10/26 [jira] [Resolved] (FLINK-41199) PyFlink result collection fails for NULL values inside nested rows and collections Dian Fu (Jira)
• 2026/10/26 Re: [PR] [FLINK-41199][python] Decode NULL values in nested collected results [flink] via GitHub
• 2026/10/26 [jira] [Commented] (FLINK-41044) CommonDataStreamTests.test_logging_msg fails with external log debug-level msg not found Dian Fu (Jira)
• 2026/10/26 [jira] [Assigned] (FLINK-41044) CommonDataStreamTests.test_logging_msg fails with external log debug-level msg not found Dian Fu (Jira)
• 2026/10/26 Re: [PR] [integration][java] Send user images and documents through the OpenAI Responses API [flink-agents] via GitHub
• 2026/10/26 Re: [PR] [FLINK-41086][table] Return NULL from `JSON_LENGTH` and `JSON_TYPE` when a JSON path function fails [flink] via GitHub
• 2026/10/26 [jira] [Updated] (FLINK-40931) ForSt restore with object-store in restore mode fails when scaling in Yuepeng Pan (Jira)
• 2026/10/26 [jira] [Updated] (FLINK-36263) Include only changed columns in old for canal format in Kakfa Sink ASF GitHub Bot (Jira)
• 2026/10/26 [PR] [FLINK-36263][pipeline-connector/kafka] Include only changed fields in Canal JSON old [flink-cdc] via GitHub
• 2026/10/26 Re: [PR] [FLINK-37834] Flink JDBC support ClickHouse Dialect [flink-connector-jdbc] via GitHub
• 2026/10/26 Re: [PR] [FLINK-37834] Flink JDBC support ClickHouse Dialect [flink-connector-jdbc] via GitHub

• Earlier messages
• Later messages