issues
Thread
Date
Earlier messages
Later messages
Messages by Date
2026/06/24
[jira] [Updated] (FLINK-39944) Dynamic Kafka source cluster removal is not resilient enough
Bowen Li (Jira)
2026/06/24
[jira] [Resolved] (FLINK-39944) Dynamic Kafka source cluster removal is not resilient enough
Bowen Li (Jira)
2026/06/24
[jira] [Commented] (FLINK-39944) Dynamic Kafka source cluster removal is not resilient enough
Bowen Li (Jira)
2026/06/24
[jira] [Updated] (FLINK-39980) Implement split rebalance/reassignment support in DynamicKafkaSource after metadata changes
ASF GitHub Bot (Jira)
2026/06/24
[PR] [FLINK-39980] Implement split rebalance/reassignment support in DynamicKafkaSource after metadata changes [flink-connector-kafka]
via GitHub
2026/06/24
[jira] [Updated] (FLINK-39990) Expose DynamicKafkaSource.activeSplitCount metric per source reader
ASF GitHub Bot (Jira)
2026/06/24
[PR] [FLINK-39990] Expose DynamicKafkaSource active split count [flink-connector-kafka]
via GitHub
2026/06/24
Re: [PR] [FLINK-39944] Make dynamic Kafka metadata refresh resilient [flink-connector-kafka]
via GitHub
2026/06/24
Re: [PR] [FLINK-39944] Make dynamic Kafka metadata refresh resilient [flink-connector-kafka]
via GitHub
2026/06/24
[PR] [FLINK-39979] DynamicKafkaSource does not mark reader idle when metadata removal leaves a subtask with no active subreaders [flink-connector-kafka]
via GitHub
2026/06/24
Re: [PR] [FLINK-39061][example] Roll back StateMachineExample to v1 State API [flink]
via GitHub
2026/06/24
Re: [PR] [hotfix][ci] Use correct property `steps.docker-cache.outputs.cache-hit` [flink]
via GitHub
2026/06/24
[PR] [hotfix][ci] Use correct property `steps.docker-cache.outputs.cache-hit` [flink]
via GitHub
2026/06/24
[jira] [Created] (FLINK-39990) Expose DynamicKafkaSource.activeSplitCount metric per source reader
Bowen Li (Jira)
2026/06/24
[jira] [Assigned] (FLINK-39990) Expose DynamicKafkaSource.activeSplitCount metric per source reader
Bowen Li (Jira)
2026/06/24
Re: [PR] [FLINK-38918][python][kafka connector] support per cluster offset for DynamicKafkaSource in pyflink [flink]
via GitHub
2026/06/24
Re: [PR] [FLINK-38918][python][kafka connector] support per cluster offset for DynamicKafkaSource in pyflink [flink]
via GitHub
2026/06/24
[jira] [Commented] (FLINK-29344) Make Adaptive Scheduler supports Fine-Grained Resource Management
Han You (Jira)
2026/06/24
[jira] [Created] (FLINK-39989) flinksessionjob stuck on "Job Not Found" if jobmanager terminates before operator learns about new job state transitions
Filippo Ghibellini (Jira)
2026/06/24
[jira] [Created] (FLINK-39988) Support composite types in filter push-down for savepoint Table API connector
Ilya Soin (Jira)
2026/06/24
[jira] [Commented] (FLINK-39725) from_source does not use timestamp assigner in pyflink
Andrew Feng (Jira)
2026/06/24
[jira] [Updated] (FLINK-36659) Release flink-connector-jdbc v4.0.0 for Flink 2.0
Yuepeng Pan (Jira)
2026/06/24
[jira] [Updated] (FLINK-36659) Release flink-connector-jdbc v4.0.0 for Flink 2.0
Yuepeng Pan (Jira)
2026/06/24
[jira] [Created] (FLINK-39987) Update docs related to flink-state-processing-api
Ilya Soin (Jira)
2026/06/24
[jira] [Updated] (FLINK-39986) Support Common Sub-Expression Elimination (CSE) for Python UDFs
raoraoxiong (Jira)
2026/06/24
[jira] [Created] (FLINK-39986) Support Common Sub-Expression Elimination (CSE) for Python UDFs
raoraoxiong (Jira)
2026/06/24
[jira] [Commented] (FLINK-35324) Avro format can not perform projection pushdown for specific fields
Calico Shop (Jira)
2026/06/24
Re: [PR] [FLINK-30975][filesystems] Upgrade to Hadoop to 3.4.3 and support AWS SDK v2 in flink-filesystem [flink]
via GitHub
2026/06/24
Re: [PR] [FLINK-32609] Support Projection Pushdown [flink-connector-kafka]
via GitHub
2026/06/24
Re: [PR] [FLINK-32609] Support Projection Pushdown [flink-connector-kafka]
via GitHub
2026/06/24
Re: [PR] [BP-2.2][FLINK-39818][ci] Filter org.eclipse.parsson:parsson false positive for Elasticsearch connector [flink]
via GitHub
2026/06/24
[jira] [Commented] (FLINK-32070) FLIP-306 Unified File Merging Mechanism for Checkpoints
Rui Fan (Jira)
2026/06/24
[PR] [BP-2.2][FLINK-39818][ci] Filter org.eclipse.parsson:parsson false positive for Elasticsearch connector [flink]
via GitHub
2026/06/24
Re: [PR] [FLINK-39816] Ship parsson into es8 uber jar [flink-connector-elasticsearch]
via GitHub
2026/06/24
Re: [PR] [FLINK-39816] Ship parsson into es8 uber jar [flink-connector-elasticsearch]
via GitHub
2026/06/24
Re: [PR] [FLINK-39680][FLINK-21378] Supports unaligned checkpoint on pointwise edges [flink]
via GitHub
2026/06/24
[jira] [Updated] (FLINK-39680) Enable unaligned checkpoint for pointwise connection by FORCE_UNALIGNED
ASF GitHub Bot (Jira)
2026/06/24
[PR] [FLINK-39680][FLINK-21378] Supports unaligned checkpoint on pointwise edges [flink]
via GitHub
2026/06/24
[jira] [Commented] (FLINK-39983) Drop FlinkPruneEmptyRules
Sergey Nuyanzin (Jira)
2026/06/24
[jira] [Resolved] (FLINK-39983) Drop FlinkPruneEmptyRules
Sergey Nuyanzin (Jira)
2026/06/24
Re: [PR] [FLINK-39983][table-planner] Remove FlinkPruneEmptyRules as Calcite 1… [flink]
via GitHub
2026/06/24
Re: [PR] [FLINK-39983][table-planner] Remove FlinkPruneEmptyRules as Calcite 1… [flink]
via GitHub
2026/06/24
[jira] [Commented] (FLINK-39982) Drop SqlCollectionTypeNameSpec and SqlJsonQueryFunction from Flink codebase
Sergey Nuyanzin (Jira)
2026/06/24
[jira] [Resolved] (FLINK-39982) Drop SqlCollectionTypeNameSpec and SqlJsonQueryFunction from Flink codebase
Sergey Nuyanzin (Jira)
2026/06/24
Re: [PR] [FLINK-39982][table] Drop `SqlCollectionTypeNameSpec` and `SqlJsonQueryFunction` from Flink codebase [flink]
via GitHub
2026/06/24
[jira] [Assigned] (FLINK-39984) Thread dump RPC can cause heartbeat timeout and unnecessary JM/TM failover
Yun Tang (Jira)
2026/06/24
[jira] [Updated] (FLINK-39759) Fix StarRocks CHAR / VARCHAR mapping rules to contain utf8mb4 characters
Leonard Xu (Jira)
2026/06/24
[jira] [Updated] (FLINK-39759) Fix StarRocks CHAR / VARCHAR mapping rules to contain utf8mb4 characters
Leonard Xu (Jira)
2026/06/24
[jira] [Resolved] (FLINK-39759) Fix StarRocks CHAR / VARCHAR mapping rules to contain utf8mb4 characters
Leonard Xu (Jira)
2026/06/24
[jira] [Assigned] (FLINK-39759) Fix StarRocks CHAR / VARCHAR mapping rules to contain utf8mb4 characters
Leonard Xu (Jira)
2026/06/24
[jira] [Closed] (FLINK-39978) Web dashboard: restyle Cancel Job/Application action as a danger button
Ferenc Csaky (Jira)
2026/06/24
Re: [PR] [FLINK-39759][starrocks] Fix CHAR/VARCHAR mapping for utf8mb4 characters [flink-cdc]
via GitHub
2026/06/24
Re: [PR] [FLINK-39978][runtime-web] Restyle Cancel Job/Application action as a danger button [flink]
via GitHub
2026/06/24
[jira] [Assigned] (FLINK-39978) Web dashboard: restyle Cancel Job/Application action as a danger button
Ferenc Csaky (Jira)
2026/06/24
[jira] [Updated] (FLINK-39978) Web dashboard: restyle Cancel Job/Application action as a danger button
Ferenc Csaky (Jira)
2026/06/24
[jira] [Updated] (FLINK-39984) Thread dump RPC can cause heartbeat timeout and unnecessary JM/TM failover
xingsuo-zbz (Jira)
2026/06/24
[jira] [Updated] (FLINK-39984) Thread dump RPC can cause heartbeat timeout and unnecessary JM/TM failover
xingsuo-zbz (Jira)
2026/06/24
[jira] [Updated] (FLINK-39984) Thread dump RPC can cause heartbeat timeout and unnecessary JM/TM failover
xingsuo-zbz (Jira)
2026/06/24
[jira] [Updated] (FLINK-39984) Thread dump RPC can cause heartbeat timeout and unnecessary JM/TM failover
xingsuo-zbz (Jira)
2026/06/24
[I] [Feature] Propagate metric groups to cross-language resources [flink-agents]
via GitHub
2026/06/24
Re: [PR] Native s3 Filesystem Blog [flink-web]
via GitHub
2026/06/24
Re: [PR] [feature][integration][java] Add built-in Google Gemini chat model integration [flink-agents]
via GitHub
2026/06/24
Re: [PR] [feature][integration][java] Add built-in Google Gemini chat model integration [flink-agents]
via GitHub
2026/06/24
Re: [PR] [dist] Add Flink 2.3 distribution and make it the default [flink-agents]
via GitHub
2026/06/24
Re: [PR] [Feature] Support tool parameter injection [flink-agents]
via GitHub
2026/06/24
Re: [PR] [Feature] Support tool parameter injection [flink-agents]
via GitHub
2026/06/24
Re: [PR] [Feature] Support tool parameter injection [flink-agents]
via GitHub
2026/06/24
Re: [PR] [FLINK-39499][tests] Replace MinIO with SeaweedFS [flink]
via GitHub
2026/06/24
Re: [PR] [Feature] Support tool parameter injection [flink-agents]
via GitHub
2026/06/24
Re: [PR] [Feature] Support tool parameter injection [flink-agents]
via GitHub
2026/06/24
Re: [PR] [FLINK-39772][tests][JUnit5 migration] Module: flink-fs-tests [flink]
via GitHub
2026/06/24
Re: [PR] [FLINK-39772][tests][JUnit5 migration] Module: flink-fs-tests [flink]
via GitHub
2026/06/24
[jira] [Commented] (FLINK-39949) [ForSt] State restore from savepoints/checkpoints not supported
Zhen Zhang (Jira)
2026/06/24
Re: [PR] [FLINK-39499][tests] Replace MinIO with SeaweedFS [flink]
via GitHub
2026/06/24
[jira] [Closed] (FLINK-39637) Filter push-down for the savepoint table connector
Gabor Somogyi (Jira)
2026/06/24
[jira] [Resolved] (FLINK-39637) Filter push-down for the savepoint table connector
Gabor Somogyi (Jira)
2026/06/24
Re: [PR] [FLINK-39772][tests][JUnit5 migration] Module: flink-fs-tests [flink]
via GitHub
2026/06/24
Re: [PR] [FLINK-39566][runtime-web] Add checkpoint duration Gantt view [flink]
via GitHub
2026/06/24
Re: [PR] [FLINK-39985] Replace ReplaceMinusWithAntiJoinRule with Calcite Minus… [flink]
via GitHub
2026/06/24
Re: [PR] [FLINK-39957][table] Support EXPLAIN of CREATE [OR ALTER] MATERIALIZED TABLE [flink]
via GitHub
2026/06/24
Re: [PR] [FLINK-39957][table] Support EXPLAIN of CREATE [OR ALTER] MATERIALIZED TABLE [flink]
via GitHub
2026/06/24
[jira] [Updated] (FLINK-39984) `requestThreadDump` blocks the JM/TM main thread and can cause heartbeat timeout / job failure
xingsuo-zbz (Jira)
2026/06/24
Re: [PR] [FLINK-39772][tests][JUnit5 migration] Module: flink-fs-tests [flink]
via GitHub
2026/06/24
[jira] [Updated] (FLINK-39985) Drop ReplaceMinusWithAntiJoinRule
ASF GitHub Bot (Jira)
2026/06/24
[PR] [FLINK-39985] Replace ReplaceMinusWithAntiJoinRule with Calcite Minus… [flink]
via GitHub
2026/06/24
[jira] [Updated] (FLINK-39984) `requestThreadDump` blocks the JM/TM main thread and can cause heartbeat timeout / job failure
xingsuo-zbz (Jira)
2026/06/24
[jira] [Updated] (FLINK-39984) `requestThreadDump` blocks the JM/TM main thread and can cause heartbeat timeout / job failure
xingsuo-zbz (Jira)
2026/06/24
[jira] [Created] (FLINK-39985) Drop ReplaceMinusWithAntiJoinRule
Jacky Lau (Jira)
2026/06/24
[jira] [Created] (FLINK-39984) `requestThreadDump` blocks the JM/TM main thread and can cause heartbeat timeout / job failure
xingsuo-zbz (Jira)
2026/06/24
[jira] [Commented] (FLINK-36334) Remove the Disable markers from the tests in the various TypeSerializerUpgradeTestBase subclasses in flink-table-api-scala module
Sergey Nuyanzin (Jira)
2026/06/24
[jira] [Assigned] (FLINK-36334) Remove the Disable markers from the tests in the various TypeSerializerUpgradeTestBase subclasses in flink-table-api-scala module
Sergey Nuyanzin (Jira)
2026/06/24
[jira] [Resolved] (FLINK-37404) Reenable Migration Tests for Filnk 2.x
Sergey Nuyanzin (Jira)
2026/06/24
Re: [PR] [FLINK-39772][tests][JUnit5 migration] Module: flink-fs-tests [flink]
via GitHub
2026/06/24
[jira] [Commented] (FLINK-37404) Reenable Migration Tests for Filnk 2.x
Sergey Nuyanzin (Jira)
2026/06/24
Re: [PR] [FLINK-37404, FLINK-36334][API / Core] Reenable Migration Tests for Filnk 2.x [flink]
via GitHub
2026/06/24
Re: [PR] [FLINK-37404, FLINK-36334][API / Core] Reenable Migration Tests for Filnk 2.x [flink]
via GitHub
2026/06/24
Re: [PR] [FLINK-39772][tests][JUnit5 migration] Module: flink-fs-tests [flink]
via GitHub
2026/06/24
Re: [PR] [FLINK-37404, FLINK-36334][API / Core] Reenable Migration Tests for Filnk 2.x [flink]
via GitHub
2026/06/24
Re: [PR] [FLINK-39983][table-planner] Remove FlinkPruneEmptyRules as Calcite 1… [flink]
via GitHub
2026/06/23
[jira] [Resolved] (FLINK-39769) [JUnit5 Migration] Module: flink-examples-streaming
Sergey Nuyanzin (Jira)
2026/06/23
[jira] [Commented] (FLINK-39769) [JUnit5 Migration] Module: flink-examples-streaming
Sergey Nuyanzin (Jira)
2026/06/23
Re: [PR] [FLINK-39769][tests][JUnit5 migration] Module: flink-examples-streaming [flink]
via GitHub
2026/06/23
[jira] [Updated] (FLINK-39983) Drop FlinkPruneEmptyRules
ASF GitHub Bot (Jira)
2026/06/23
[PR] [FLINK-39983][table-planner] Remove FlinkPruneEmptyRules as Calcite 1… [flink]
via GitHub
2026/06/23
[jira] [Created] (FLINK-39983) Drop FlinkPruneEmptyRules
Jacky Lau (Jira)
2026/06/23
Re: [PR] [FLINK-39982][table] Drop `SqlCollectionTypeNameSpec` and `SqlJsonQueryFunction` from Flink codebase [flink]
via GitHub
2026/06/23
Re: [PR] [FLINK-39982][table] Drop `SqlCollectionTypeNameSpec` and `SqlJsonQueryFunction` from Flink codebase [flink]
via GitHub
2026/06/23
Re: [PR] [FLINK-39982][table] Drop `SqlCollectionTypeNameSpec` and `SqlJsonQueryFunction` from Flink codebase [flink]
via GitHub
2026/06/23
Re: [PR] [FLINK-39982][table] Drop `SqlCollectionTypeNameSpec` and `SqlJsonQueryFunction` from Flink codebase [flink]
via GitHub
2026/06/23
Re: [PR] [FLINK-39982][table] Drop `SqlCollectionTypeNameSpec` and `SqlJsonQueryFunction` from Flink codebase [flink]
via GitHub
2026/06/23
[jira] [Updated] (FLINK-39982) Drop SqlCollectionTypeNameSpec and SqlJsonQueryFunction from Flink codebase
ASF GitHub Bot (Jira)
2026/06/23
[PR] [FLINK-39982][table] Drop `SqlCollectionTypeNameSpec` and `SqlJsonQueryFunction` from Flink codebase [flink]
via GitHub
2026/06/23
Re: [PR] [FLINK-39772][tests][JUnit5 migration] Module: flink-fs-tests [flink]
via GitHub
2026/06/23
[jira] [Created] (FLINK-39982) Drop SqlCollectionTypeNameSpec and SqlJsonQueryFunction from Flink codebase
Sergey Nuyanzin (Jira)
2026/06/23
Re: [PR] [FLINK-39772][tests][JUnit5 migration] Module: flink-fs-tests [flink]
via GitHub
2026/06/23
Re: [PR] [FLINK-39931] Fix flaky AdaptiveBatchSchedulerTest due to unexpected ComponentMainThreadExecutor behavior in async execution [flink]
via GitHub
2026/06/23
[PR] [dist] Add Flink 2.3 distribution and CI coverage [flink-agents]
via GitHub
2026/06/23
[jira] [Commented] (FLINK-39980) Implement split rebalance/reassignment support in DynamicKafkaSource after metadata changes
Taranpreet Kaur (Jira)
2026/06/23
Re: [PR] [FLINK-39931] Fix flaky AdaptiveBatchSchedulerTest due to unexpected ComponentMainThreadExecutor behavior in async execution [flink]
via GitHub
2026/06/23
[jira] [Commented] (FLINK-39929) Fix the flaky test case ExecutionTimeBasedSlowTaskDetectorTest due to unexepected ComponentMainThreadExecutor setting.
Yuepeng Pan (Jira)
2026/06/23
[jira] [Resolved] (FLINK-39929) Fix the flaky test case ExecutionTimeBasedSlowTaskDetectorTest due to unexepected ComponentMainThreadExecutor setting.
Yuepeng Pan (Jira)
2026/06/23
Re: [PR] [FLINK-39929][runtime/tests] Fix the flaky test case ExecutionTimeBasedSlowTaskDetectorTest due to unexepected ComponentMainThreadExecutor setting. [flink]
via GitHub
2026/06/23
Re: [PR] [FLINK-39759][starrocks] Fix CHAR/VARCHAR mapping for utf8mb4 characters [flink-cdc]
via GitHub
2026/06/23
[jira] [Comment Edited] (FLINK-39966) FlinkRelMdModifiedMonotonicity wrongly reports a non-time-attribute Top-1 Rank as insert-only
lincoln lee (Jira)
2026/06/23
[jira] [Updated] (FLINK-39966) FlinkRelMdModifiedMonotonicity wrongly reports a non-time-attribute Top-1 Rank as insert-only
lincoln lee (Jira)
2026/06/23
Re: [PR] [BP-2.2][FLINK-39966][table-planner] FlinkRelMdModifiedMonotonicity wrongly reports a non-time-attribute Top-1 Rank as insert-only [flink]
via GitHub
2026/06/23
Re: [PR] [BP-2.3][FLINK-39966][table-planner] FlinkRelMdModifiedMonotonicity wrongly reports a non-time-attribute Top-1 Rank as insert-only [flink]
via GitHub
2026/06/23
Re: [PR] [minor][pipeline-connector/sqlserver] Fix SQL Server schema restore without per-record JDBC [flink-cdc]
via GitHub
2026/06/23
Re: [PR] [FLINK-39859][table] Upgrade Calcite to 1.41.0 [flink]
via GitHub
2026/06/23
Re: [PR] [FLINK-39859][table] Upgrade Calcite to 1.41.0 [flink]
via GitHub
2026/06/23
Re: [PR] [Feature] Support tool parameter injection [flink-agents]
via GitHub
2026/06/23
Re: [PR] [FLINK-39034][streaming] Fix timestamp loss in SortPartitionOperator [flink]
via GitHub
2026/06/23
Re: [PR] [FLINK-39929][runtime/tests] Fix the flaky test case ExecutionTimeBasedSlowTaskDetectorTest due to unexepected ComponentMainThreadExecutor setting. [flink]
via GitHub
2026/06/23
Re: [PR] [Feature] Support tool parameter injection [flink-agents]
via GitHub
2026/06/23
[jira] [Created] (FLINK-39981) Autoscaler cannot trigger source rebalance after active split removal on dynamic Kafka source
Xin Gao (Jira)
2026/06/23
Re: [PR] [FLINK-39979][Connectors/Kafka] Mark DynamicKafkaSource reader idle when metadata removes all active clusters [flink-connector-kafka]
via GitHub
2026/06/23
[jira] [Updated] (FLINK-39979) DynamicKafkaSource does not mark reader idle when metadata removal leaves a subtask with no active subreaders
ASF GitHub Bot (Jira)
2026/06/23
[PR] [FLINK-39979][Connectors/Kafka] Mark DynamicKafkaSource reader idle when metadata removes all active clusters [flink-connector-kafka]
via GitHub
2026/06/23
[jira] [Assigned] (FLINK-39980) Implement split rebalance/reassignment support in DynamicKafkaSource after metadata changes
Bowen Li (Jira)
2026/06/23
[jira] [Created] (FLINK-39980) Implement split rebalance/reassignment support in DynamicKafkaSource after metadata changes
Bowen Li (Jira)
2026/06/23
Re: [PR] [FLINK-38918][python][kafka connector] support per cluster offset for DynamicKafkaSource in pyflink [flink]
via GitHub
2026/06/23
Re: [PR] [FLINK-38918][python][kafka connector] support per cluster offset for DynamicKafkaSource in pyflink [flink]
via GitHub
2026/06/23
Re: [PR] [FLINK-38918][python][kafka connector] support per cluster offset for DynamicKafkaSource in pyflink [flink]
via GitHub
2026/06/23
[jira] [Created] (FLINK-39979) DynamicKafkaSource does not mark reader idle when metadata removal leaves a subtask with no active subreaders
Bowen Li (Jira)
2026/06/23
[jira] [Assigned] (FLINK-39979) DynamicKafkaSource does not mark reader idle when metadata removal leaves a subtask with no active subreaders
Bowen Li (Jira)
2026/06/23
[jira] [Commented] (FLINK-39137) Add configurable delay between non-empty GetRecords calls in Kinesis source
Jing Hung (Jira)
2026/06/23
Re: [PR] [FLINK-36317][runtime] Populate ArchivedExecutionGraph with CheckpointStatsSnapshot in WaitingForResources state [flink]
via GitHub
2026/06/23
Re: [PR] [FLINK-36317][runtime] Populate ArchivedExecutionGraph with CheckpointStatsSnapshot in WaitingForResources state [flink]
via GitHub
2026/06/23
Re: [PR] [FLINK-39637][state] Add filter pushdown support for savepoint connector [flink]
via GitHub
2026/06/23
Re: [PR] [FLINK-36317] Populate ArchivedExecutionGraph with CheckpointStatsSnapshot in WaitingForResources state [flink]
via GitHub
2026/06/23
Re: [PR] [FLINK-37404, FLINK-36334][API / Core] Reenable Migration Tests for Filnk 2.x [flink]
via GitHub
2026/06/23
Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink]
via GitHub
2026/06/23
Re: [PR] [FLINK-36317] Populate ArchivedExecutionGraph with CheckpointStatsSnapshot in WaitingForResources state [flink]
via GitHub
2026/06/23
Re: [PR] [FLINK-37288] Add Google Cloud Spanner dialect and catalog [flink-connector-jdbc]
via GitHub
2026/06/23
[jira] [Updated] (FLINK-36317) Populate the ArchivedExecutionGraph with CheckpointStatsSnapshot data if in WaitingForResources state with a previousExecutionGraph being set
ASF GitHub Bot (Jira)
2026/06/23
[PR] [FLINK-36317] Populate ArchivedExecutionGraph with CheckpointStatsSnapshot in WaitingForResources state [flink]
via GitHub
2026/06/23
Re: [PR] [hotfix] Add HTTP connector 1.0 docs [flink]
via GitHub
2026/06/23
Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink]
via GitHub
2026/06/23
[jira] [Commented] (FLINK-39852) Translate documentation to Chinese
Yibo Cao (Jira)
2026/06/23
Re: [PR] [FLINK-39637][state] Add filter pushdown support for savepoint connector [flink]
via GitHub
2026/06/23
[jira] [Updated] (FLINK-39978) Web dashboard: restyle Cancel Job/Application action as a danger button
Purushottam Sinha (Jira)
2026/06/23
[jira] [Updated] (FLINK-39978) Web dashboard: restyle Cancel Job/Application action as a danger button
Purushottam Sinha (Jira)
2026/06/23
Re: [PR] [drfat] [minor][pipeline-connector/sqlserver] Fix SQL Server schema restore without per-record JDBC [flink-cdc]
via GitHub
2026/06/23
[jira] [Updated] (FLINK-39978) Web dashboard: restyle Cancel Job/Application action as a danger button
Purushottam Sinha (Jira)
2026/06/23
[jira] [Updated] (FLINK-39978) Web dashboard: restyle Cancel Job/Application action as a danger button
Purushottam Sinha (Jira)
2026/06/23
[jira] [Updated] (FLINK-39978) Web dashboard: restyle Cancel Job/Application action as a danger button
Purushottam Sinha (Jira)
2026/06/23
Re: [PR] [FLINK-39637][state] Add filter pushdown support for savepoint connector [flink]
via GitHub
2026/06/23
[jira] [Updated] (FLINK-39978) Web dashboard: restyle Cancel Job/Application action as a danger button
Purushottam Sinha (Jira)
2026/06/23
Re: [PR] [FLINK-39637][state] Add filter pushdown support for savepoint connector [flink]
via GitHub
2026/06/23
[jira] [Commented] (FLINK-39637) Filter push-down for the savepoint table connector
Gabor Somogyi (Jira)
2026/06/23
[jira] [Updated] (FLINK-39978) Web dashboard: restyle Cancel Job/Application action as a danger button
Purushottam Sinha (Jira)
2026/06/23
[jira] [Updated] (FLINK-39978) Web dashboard: restyle Cancel Job/Application action as a danger button
ASF GitHub Bot (Jira)
2026/06/23
Re: [PR] [FLINK-39978][runtime-web] Restyle Cancel Job/Application action as a danger button [flink]
via GitHub
2026/06/23
[jira] [Created] (FLINK-39978) Web dashboard: restyle Cancel Job/Application action as a danger button
Purushottam Sinha (Jira)
2026/06/23
Re: [PR] [FLINK-37027][docs] Translate TO_TIMESTAMP_LTZ descriptions [flink]
via GitHub
2026/06/23
Re: [PR] [hotfix][runtime-web] Restyle Cancel Job/Application action as a danger button [flink]
via GitHub
2026/06/23
[jira] [Resolved] (FLINK-39975) Flaky DerbyDynamicTableSourceITCase.testLimit: JdbcSourceSplitReader does not recover from a connection closed during source cancellation
Yuepeng Pan (Jira)
2026/06/23
[jira] [Commented] (FLINK-39975) Flaky DerbyDynamicTableSourceITCase.testLimit: JdbcSourceSplitReader does not recover from a connection closed during source cancellation
Yuepeng Pan (Jira)
2026/06/23
Re: [PR] [FLINK-39975][jdbc] Recover JdbcSourceSplitReader from a connection closed during cancellation [flink-connector-jdbc]
via GitHub
2026/06/23
Re: [PR] [FLINK-39975][jdbc] Recover JdbcSourceSplitReader from a connection closed during cancellation [flink-connector-jdbc]
via GitHub
2026/06/23
Re: [PR] [FLINK-36456] feat: Add support to pass Datadog API Key as environment variable [flink]
via GitHub
2026/06/23
Re: [PR] [BP-2.3][FLINK-39966][table-planner] FlinkRelMdModifiedMonotonicity wrongly reports a non-time-attribute Top-1 Rank as insert-only [flink]
via GitHub
2026/06/23
Re: [PR] Release 2.3 dockerfiles [flink-docker]
via GitHub
2026/06/23
[jira] [Comment Edited] (FLINK-32070) FLIP-306 Unified File Merging Mechanism for Checkpoints
Zakelly Lan (Jira)
2026/06/23
[jira] [Updated] (FLINK-39977) Recovery of merged channel state in Unified File Merging Framework
Zakelly Lan (Jira)
2026/06/23
[jira] [Commented] (FLINK-32070) FLIP-306 Unified File Merging Mechanism for Checkpoints
Zakelly Lan (Jira)
2026/06/23
[jira] [Created] (FLINK-39977) Recovery of merged channel state in Unified File Merging Framework
Zakelly Lan (Jira)
2026/06/23
Re: [PR] [FLINK-37404, FLINK-36334][API / Core] Reenable Migration Tests for Filnk 2.x [flink]
via GitHub
2026/06/23
[PR] [BP-2.2][FLINK-39966][table-planner] FlinkRelMdModifiedMonotonicity wrongly reports a non-time-attribute Top-1 Rank as insert-only [flink]
via GitHub
2026/06/23
Re: [PR] [BP-2.2][FLINK-39966][table-planner] FlinkRelMdModifiedMonotonicity wrongly reports a non-time-attribute Top-1 Rank as insert-only [flink]
via GitHub
2026/06/23
Re: [PR] [BP-2.3][FLINK-39966][table-planner] FlinkRelMdModifiedMonotonicity wrongly reports a non-time-attribute Top-1 Rank as insert-only [flink]
via GitHub
2026/06/23
Re: [PR] Native s3 Filesystem Blog [flink-web]
via GitHub
2026/06/23
Re: [PR] [hotfix][table-planner] HiveCatalog store filesystem connector partit… [flink]
via GitHub
2026/06/23
[jira] (FLINK-39929) Fix the flaky test case ExecutionTimeBasedSlowTaskDetectorTest due to unexepected ComponentMainThreadExecutor setting.
Chanhae Oh (Jira)
2026/06/23
[jira] (FLINK-39929) Fix the flaky test case ExecutionTimeBasedSlowTaskDetectorTest due to unexepected ComponentMainThreadExecutor setting.
Chanhae Oh (Jira)
2026/06/23
Re: [PR] [FLINK-39975][jdbc] Recover JdbcSourceSplitReader from a connection closed during cancellation [flink-connector-jdbc]
via GitHub
2026/06/23
Re: [PR] [hotfix][runtime-web] Restyle Cancel Job/Application action as a danger button [flink]
via GitHub
2026/06/23
[jira] [Updated] (FLINK-39975) Flaky DerbyDynamicTableSourceITCase.testLimit: JdbcSourceSplitReader does not recover from a connection closed during source cancellation
Yuepeng Pan (Jira)
2026/06/23
Re: [PR] [FLINK-38544][checkpoint] Support spilling for checkpointing during recovery [flink]
via GitHub
2026/06/23
Re: [PR] [FLINK-39975][jdbc] Recover JdbcSourceSplitReader from a connection closed during cancellation [flink-connector-jdbc]
via GitHub
Earlier messages
Later messages