issues  

Messages by Date

• 2026/06/18 [PR] [hotfix][table] Fix view comment derived from QueryOperation summary string [flink] via GitHub
• 2026/06/18 Re: [PR] [BP-2.0][FLINK-37663][connector-base] Fix lost wakeup in FutureCompletingBlockingQueue [flink] via GitHub
• 2026/06/18 Re: [PR] [BP-2.3][FLINK-37663][connector-base] Fix lost wakeup in FutureCompletingBlockingQueue [flink] via GitHub
• 2026/06/18 Re: [PR] [hotfix] Regenerate CRDs with new Fabric8 generator [flink-kubernetes-operator] via GitHub
• 2026/06/18 Re: [PR] [FLINK-39952][Table SQL/Planner] Fix CallContextMock.isArgumentNull() to correctly handle optional arguments [flink] via GitHub
• 2026/06/18 [jira] [Updated] (FLINK-39931) Fix flaky AdaptiveBatchSchedulerTest due to unexpected ComponentMainThreadExecutor behavior in async execution ASF GitHub Bot (Jira)
• 2026/06/18 Re: [PR] [FLINK-39931] Fix flaky AdaptiveBatchSchedulerTest due to unexpected ComponentMainThreadExecutor behavior in async execution [flink] via GitHub
• 2026/06/18 Re: [PR] [FLINK-39782][table] Add SNAPSHOT built-in function definition and type inference [flink] via GitHub
• 2026/06/18 [jira] [Resolved] (FLINK-39792) Add multi-headers metadata key to Kafka connector Arvid Heise (Jira)
• 2026/06/18 [jira] [Commented] (FLINK-39792) Add multi-headers metadata key to Kafka connector Arvid Heise (Jira)
• 2026/06/18 [jira] [Commented] (FLINK-39792) Add multi-headers metadata key to Kafka connector Arvid Heise (Jira)
• 2026/06/18 Re: [PR] [FLINK-39792] Add multi-headers metadata key to Kafka connector [flink-connector-kafka] via GitHub
• 2026/06/18 Re: [PR] [hotfix] Regenerate CRDs with new Fabric8 generator [flink-kubernetes-operator] via GitHub
• 2026/06/18 Re: [PR] [FLINK-39637][state] Add filter pushdown support for savepoint connector [flink] via GitHub
• 2026/06/18 Re: [PR] [Flink 39931][runtime/tests] Verify stability of testVertexInitializationFailureIsLabeled and testUnbalancedInput with RepeatedTest [flink] via GitHub
• 2026/06/18 [PR] [Flink 39931][runtime/tests] Verify stability of testVertexInitializationFailureIsLabeled and testUnbalancedInput with RepeatedTest [flink] via GitHub
• 2026/06/18 Re: [PR] [FLINK-39125][table] Support injective casts from BINARY/VARBINARY to CHAR/VARCHAR for upsert keys [flink] via GitHub
• 2026/06/18 [jira] [Updated] (FLINK-39125) Support injective casts from BINARY/VARBINARY to CHAR/VARCHAR for upsert key preservation ASF GitHub Bot (Jira)
• 2026/06/18 [PR] [FLINK-39125][table] Support injective casts from BINARY/VARBINARY to… [flink] via GitHub
• 2026/06/18 [jira] [Updated] (FLINK-39125) Support injective casts from BINARY/VARBINARY to CHAR/VARCHAR for upsert key preservation Gustavo de Morais (Jira)
• 2026/06/18 [jira] [Updated] (FLINK-39125) Support injective casts from BINARY/VARBINARY to CHAR/VARCHAR for upsert key preservation Gustavo de Morais (Jira)
• 2026/06/18 [PR] [hotfix] Regenerate CRDs with new Fabric8 generator [flink-kubernetes-operator] via GitHub
• 2026/06/18 Re: [PR] [FLINK-33548] Replace taskManager/jobmanager.resource with resources conforming to ResourceRequirements [flink-kubernetes-operator] via GitHub
• 2026/06/18 Re: [PR] [FLINK-37351][runtime] Ensure writer and committer are colocated for non-pre-commit topologies [flink] via GitHub
• 2026/06/18 [jira] [Created] (FLINK-39955) PTF OutputTypeStrategy can emit time indicator types Fabian Hueske (Jira)
• 2026/06/18 Re: [PR] [FLINK-39792] Add multi-headers metadata key to Kafka connector [flink-connector-kafka] via GitHub
• 2026/06/18 [jira] [Commented] (FLINK-37351) Ensure writer and committer are colocated Arvind Kandpal (Jira)
• 2026/06/18 [PR] [FLINK-37351][runtime] Ensure writer and committer are colocated for non-pre-commit topologies [flink] via GitHub
• 2026/06/18 Re: [PR] [FLINK-37351][runtime] Ensure writer and committer are colocated for non-pre-commit topologies [flink] via GitHub
• 2026/06/18 [PR] [Feature] Support tool parameter injection [flink-agents] via GitHub
• 2026/06/18 [I] [Feature] Support tool parameter injection [flink-agents] via GitHub
• 2026/06/18 Re: [PR] [FLINK-38449][core] Reject fractional MemorySize values with explicit error [flink] via GitHub
• 2026/06/18 [PR] [FLINK-38449][core] Reject fractional MemorySize values with explicit error [flink] via GitHub
• 2026/06/18 [jira] [Closed] (FLINK-39913) Improve the error message for unsupported changelog modes Timo Walther (Jira)
• 2026/06/18 [jira] [Updated] (FLINK-39913) Improve the error message for unsupported changelog modes Timo Walther (Jira)
• 2026/06/18 [jira] [Updated] (FLINK-39913) Improve the error message for unsupported changelog modes Timo Walther (Jira)
• 2026/06/18 [jira] [Updated] (FLINK-39913) Improve the error message for unsupported changelog modes Timo Walther (Jira)
• 2026/06/18 Re: [PR] [FLINK-39913][table] Improve the error message when a foreground query emits an upsert changelog [flink] via GitHub
• 2026/06/18 Re: [PR] [FLINK-39145][checkpointing] Account for already closed classloader during async operation failure [flink] via GitHub
• 2026/06/18 Re: [PR] [FLINK-39079][Web Frontend] Add Diagnosis Advisor to Flink Web UI [flink] via GitHub
• 2026/06/18 Re: [PR] [api][java][python] Introduce EventType constants and unify Action trigger entry [flink-agents] via GitHub
• 2026/06/18 Re: [PR] [FLINK-38498]Fix JDBC Connector Data Type Mapping lacks: Mysql Timestamp and Postgres Timestamp_tz [flink-connector-jdbc] via GitHub
• 2026/06/18 [PR] [FLINK-35140][pipeline-connector/kafka] Add kafka pipeline data source connector [flink-cdc] via GitHub
• 2026/06/18 Re: [PR] Announce Flink Agents 0.3.0 [flink-web] via GitHub
• 2026/06/17 Re: [PR] Announce Flink Agents 0.3.0 [flink-web] via GitHub
• 2026/06/17 Re: [PR] [FLINK-39122][table] Reject out-of-range decimal constant arguments [flink] via GitHub
• 2026/06/17 [jira] [Commented] (FLINK-39925) Job throughput metrics incorrectly dropping to zero, forcing scale down Swati Gupta (Jira)
• 2026/06/17 Re: [PR] [hotfix][docs] Remove broken JavaDoc shortcode usage from JDBC docs [flink-connector-jdbc] via GitHub
• 2026/06/17 Re: [PR] [hotfix][docs] Remove broken JavaDoc shortcode usage from JDBC docs [flink-connector-jdbc] via GitHub
• 2026/06/17 [PR] 11:45 AM[FLINK-39925][Autoscaler] Skip scaling decisions when vertex IO metrics are incomplete to prevent incorrect scale down [flink-kubernetes-operator] via GitHub
• 2026/06/17 Re: [PR] [FLINK-39952][Table SQL/Planner] Fix CallContextMock.isArgumentNull() to correctly handle optional arguments [flink] via GitHub
• 2026/06/17 [jira] [Updated] (FLINK-38733) Allow more dynamic splitter on JdbcSource Yuepeng Pan (Jira)
• 2026/06/17 [jira] [Updated] (FLINK-38733) Allow more dynamic splitter on JdbcSource Yuepeng Pan (Jira)
• 2026/06/17 [jira] [Commented] (FLINK-38733) Allow more dynamic splitter on JdbcSource Yuepeng Pan (Jira)
• 2026/06/17 Re: [PR] [FLINK-38733] Add new SplitterEnumerator on JdbcSource [flink-connector-jdbc] via GitHub
• 2026/06/17 Re: [PR] [FLINK-38733] Add new SplitterEnumerator on JdbcSource [flink-connector-jdbc] via GitHub
• 2026/06/17 Re: [PR] [FLINK-38144][state] Fix changelog state backend NPE with null map state values [flink] via GitHub
• 2026/06/17 Re: [PR] [DEBUG PR - DO NOT MERGE][FLINK-39481] Trace window-aggregate restore data loss [flink] via GitHub
• 2026/06/17 Re: [PR] [FLINK-35562][table-planner] Bound result wait in RestoreTestBase to avoid CI hangs [flink] via GitHub
• 2026/06/17 Re: [PR] [FLINK-38498]Fix JDBC Connector Data Type Mapping lacks: Mysql Timestamp and Postgres Timestamp_tz [flink-connector-jdbc] via GitHub
• 2026/06/17 Re: [PR] Announce Flink Agents 0.3.0 [flink-web] via GitHub
• 2026/06/17 [jira] [Updated] (FLINK-39759) Fix StarRocks CHAR / VARCHAR mapping rules to contain utf8mb4 characters Mao Jiayi (Jira)
• 2026/06/17 Re: [PR] [Flink-39911][historyserver] Support Pluggable Storage Backend for HistoryServer [flink] via GitHub
• 2026/06/17 Re: [PR] [Flink-39911][historyserver] Support Pluggable Storage Backend for HistoryServer [flink] via GitHub
• 2026/06/17 Re: [PR] [Flink-39911][historyserver] Support Pluggable Storage Backend for HistoryServer [flink] via GitHub
• 2026/06/17 Re: [PR] [BP-2.3][FLINK-39936][dist] Add flink-s3-fs-native to flink-dist pom file [flink] via GitHub
• 2026/06/17 [PR] [FLINK-39936][dist] Add flink-s3-fs-native to flink-dist pom file [flink] via GitHub
• 2026/06/17 [jira] [Closed] (FLINK-29984) Flink Histogram not emitting min and max when using Prometheus Reporter Bowen Li (Jira)
• 2026/06/17 [jira] [Commented] (FLINK-29984) Flink Histogram not emitting min and max when using Prometheus Reporter Bowen Li (Jira)
• 2026/06/17 [jira] [Commented] (FLINK-39940) DynamicKafkaSource should refresh restored cluster properties from KafkaMetadataService Bowen Li (Jira)
• 2026/06/17 [jira] [Resolved] (FLINK-39940) DynamicKafkaSource should refresh restored cluster properties from KafkaMetadataService Bowen Li (Jira)
• 2026/06/17 Re: [PR] [hotfix][docs] Remove broken JavaDoc shortcode usage from JDBC docs [flink-connector-jdbc] via GitHub
• 2026/06/17 Re: [PR] [FLINK-29984][flink-metrics] Export Prometheus histogram min and max [flink] via GitHub
• 2026/06/17 Re: [PR] [BP-1.20][FLINK-37663][connector-base] Fix lost wakeup in FutureCompletingBlockingQueue [flink] via GitHub
• 2026/06/17 Re: [PR] [BP-2.1][FLINK-37663][connector-base] Fix lost wakeup in FutureCompletingBlockingQueue [flink] via GitHub
• 2026/06/17 Re: [PR] [BP-2.0][FLINK-37663][connector-base] Fix lost wakeup in FutureCompletingBlockingQueue [flink] via GitHub
• 2026/06/17 [jira] [Commented] (FLINK-38534) Fix flaky LocalRecoveryTest by waiting for tasks to reach RUNNING state Martijn Visser (Jira)
• 2026/06/17 Re: [PR] [BP-2.2][FLINK-37663][connector-base] Fix lost wakeup in FutureCompletingBlockingQueue [flink] via GitHub
• 2026/06/17 Re: [PR] [BP-2.3][FLINK-37663][connector-base] Fix lost wakeup in FutureCompletingBlockingQueue [flink] via GitHub
• 2026/06/17 Re: [PR] [FLINK-38534][runtime/tests] Fix LocalRecoveryTest racing the async task deployment [flink] via GitHub
• 2026/06/17 [jira] [Commented] (FLINK-39949) [ForSt] State restore from savepoints/checkpoints not supported Martijn Visser (Jira)
• 2026/06/17 [jira] [Updated] (FLINK-39949) [ForSt] State restore from savepoints/checkpoints not supported Jubin Soni (Jira)
• 2026/06/17 [jira] [Commented] (FLINK-39949) [ForSt] State restore from savepoints/checkpoints not supported Jubin Soni (Jira)
• 2026/06/17 [jira] [Updated] (FLINK-39949) [ForSt] State restore from savepoints/checkpoints not supported Jubin Soni (Jira)
• 2026/06/17 [jira] [Created] (FLINK-39954) SinkV2ITCase over-asserts commit multiplicity under unaligned checkpoints Martijn Visser (Jira)
• 2026/06/17 [jira] [Commented] (FLINK-38614) SinkV2ITCase.writerAndCommitterExecuteInStreamingModeWithScaling failed in test_cron_adaptive_scheduler tests Martijn Visser (Jira)
• 2026/06/17 Re: [PR] [FLINK-38614][runtime] Defer EndOfData until final checkpoint committables are emitted [flink] via GitHub
• 2026/06/17 [jira] [Updated] (FLINK-38614) SinkV2ITCase.writerAndCommitterExecuteInStreamingModeWithScaling failed in test_cron_adaptive_scheduler tests ASF GitHub Bot (Jira)
• 2026/06/17 [PR] [FLINK-38614][runtime] Defer EndOfData until final checkpoint committables are emitted [flink] via GitHub
• 2026/06/17 [jira] [Commented] (FLINK-39949) [ForSt] State restore from savepoints/checkpoints not supported Martijn Visser (Jira)
• 2026/06/17 Re: [PR] [FLINK-39952][Table SQL/Planner] Fix CallContextMock.isArgumentNull() to correctly handle optional arguments [flink] via GitHub
• 2026/06/17 [jira] [Commented] (FLINK-34368) Update GCS filesystems to latest available version v3.0 Luca Castelli (Jira)
• 2026/06/17 Re: [I] [Feature] [runtime] Support batched summarization for long-term memory. [flink-agents] via GitHub
• 2026/06/17 Re: [PR] [FLINK-29984][flink-metrics] Export Prometheus histogram min and max [flink] via GitHub
• 2026/06/17 Re: [PR] [FLINK-39122][table] Reject out-of-range decimal constant arguments [flink] via GitHub
• 2026/06/17 Re: [PR] [FLINK-39952][Table SQL/Planner] Fix CallContextMock.isArgumentNull() to correctly handle optional arguments [flink] via GitHub
• 2026/06/17 [jira] [Updated] (FLINK-39952) CallContextMock.isArgumentNull() does not correctly implement interface contract ASF GitHub Bot (Jira)
• 2026/06/17 [PR] [FLINK-39952][Table SQL/Planner] Fix CallContextMock.isArgumentNull() to correctly handle optional arguments [flink] via GitHub
• 2026/06/17 Re: [PR] [FLINK-39940] DynamicKafkaSource should refresh restored cluster properties from KafkaMetadataService [flink-connector-kafka] via GitHub
• 2026/06/17 Re: [PR] [FLINK-39837] Retain removed dynamic Kafka cluster offsets [flink-connector-kafka] via GitHub
• 2026/06/17 Re: [PR] [FLINK-39837] Retain removed dynamic Kafka cluster offsets [flink-connector-kafka] via GitHub
• 2026/06/17 Re: [PR] [FLINK-39940] DynamicKafkaSource should refresh restored cluster properties from KafkaMetadataService [flink-connector-kafka] via GitHub
• 2026/06/17 [jira] [Comment Edited] (FLINK-39925) Job throughput metrics incorrectly dropping to zero, forcing scale down Trystan (Jira)
• 2026/06/17 [jira] [Commented] (FLINK-39925) Job throughput metrics incorrectly dropping to zero, forcing scale down Trystan (Jira)
• 2026/06/17 Re: [PR] [FLINK-39122][table] Reject out-of-range decimal constant arguments [flink] via GitHub
• 2026/06/17 Re: [PR] [FLINK-38918][PyFlink] Support per cluster offset for DynamicKafkaSource in pyflink [flink] via GitHub
• 2026/06/17 Re: [PR] [FLINK-39791][helm] Honor defaultConfiguration.config.yaml and always mount config.yaml [flink-kubernetes-operator] via GitHub
• 2026/06/17 Re: [PR] [FLINK-39139] Update lz4-java to 1.10.3 [flink] via GitHub
• 2026/06/17 [jira] [Updated] (FLINK-39940) DynamicKafkaSource should refresh restored cluster properties from KafkaMetadataService ASF GitHub Bot (Jira)
• 2026/06/17 Re: [PR] [FLINK-39940] DynamicKafkaSource should refresh restored cluster properties from KafkaMetadataService [flink-connector-kafka] via GitHub
• 2026/06/17 Re: [PR] [FLINK-38534][runtime/tests] Fix LocalRecoveryTest racing the async task deployment [flink] via GitHub
• 2026/06/17 [jira] [Commented] (FLINK-39925) Job throughput metrics incorrectly dropping to zero, forcing scale down Swati Gupta (Jira)
• 2026/06/17 Re: [PR] [FLINK-39782][table] Add SNAPSHOT built-in function definition and type inference [flink] via GitHub
• 2026/06/17 Re: [PR] [FLINK-39782][table] Add SNAPSHOT built-in function definition and type inference [flink] via GitHub
• 2026/06/17 [jira] [Comment Edited] (FLINK-39925) Job throughput metrics incorrectly dropping to zero, forcing scale down Trystan (Jira)
• 2026/06/17 [jira] [Comment Edited] (FLINK-39925) Job throughput metrics incorrectly dropping to zero, forcing scale down Trystan (Jira)
• 2026/06/17 [jira] [Commented] (FLINK-39925) Job throughput metrics incorrectly dropping to zero, forcing scale down Trystan (Jira)
• 2026/06/17 Re: [PR] [FLINK-39782][table] Add SNAPSHOT built-in function definition and type inference [flink] via GitHub
• 2026/06/17 [jira] [Updated] (FLINK-39925) Job throughput metrics incorrectly dropping to zero, forcing scale down Trystan (Jira)
• 2026/06/17 [PR] [test] Try to Fix flaky tests with AI assistance [flink-cdc] via GitHub
• 2026/06/17 [jira] [Created] (FLINK-39953) AbstractFlinkService.deleteBlocking() swallows KubernetesClientTimeoutException allowing cluster upgrade to proceed on top of still-running cluster Lucas Borges (Jira)
• 2026/06/17 Re: [PR] [FLINK-31244][core] Capture expected IllegalStateException on concurrent free in OffHeapUnsafeMemorySegmentTest [flink] via GitHub
• 2026/06/17 Re: [PR] [FLINK-38918][PyFlink] Support per cluster offset for DynamicKafkaSource in pyflink [flink] via GitHub
• 2026/06/17 Re: [PR] [FLINK-39782][table] Add SNAPSHOT built-in function definition and type inference [flink] via GitHub
• 2026/06/17 [jira] [Created] (FLINK-39952) CallContextMock.isArgumentNull() does not correctly implement interface contract Fabian Hueske (Jira)
• 2026/06/17 [jira] [Commented] (FLINK-39925) Job throughput metrics incorrectly dropping to zero, forcing scale down Swati Gupta (Jira)
• 2026/06/17 Re: [PR] [FLINK-39925][Autoscaler] Return NaN instead of 0 for edge output ratio when input metrics are unavailable [flink-kubernetes-operator] via GitHub
• 2026/06/17 Re: [PR] [FLINK-39782][table] Add SNAPSHOT built-in function definition and type inference [flink] via GitHub
• 2026/06/17 Re: [PR] [FLINK-37663][connector-base] Fix lost wakeup in FutureCompletingBlockingQueue [flink] via GitHub
• 2026/06/17 [jira] [Commented] (FLINK-39925) Job throughput metrics incorrectly dropping to zero, forcing scale down Trystan (Jira)
• 2026/06/17 Re: [PR] [FLINK-39913][table] Improve the error message when a foreground query emits an upsert changelog [flink] via GitHub
• 2026/06/17 [jira] [Assigned] (FLINK-39511) FLIP-514: Custom Evaluator plugin for Flink Autoscaler Gyula Fora (Jira)
• 2026/06/17 [jira] [Closed] (FLINK-39511) FLIP-514: Custom Evaluator plugin for Flink Autoscaler Gyula Fora (Jira)
• 2026/06/17 [jira] [Commented] (FLINK-39511) FLIP-514: Custom Evaluator plugin for Flink Autoscaler Gyula Fora (Jira)
• 2026/06/17 Re: [PR] [FLINK-39511] FLIP-514: Custom Evaluator plugin for Flink Autoscaler [flink-kubernetes-operator] via GitHub
• 2026/06/17 [PR] [FLINK-XXXXX] Fix cluster deletion timeout silently swallowed during upgrade [flink-kubernetes-operator] via GitHub
• 2026/06/17 Re: [PR] [FLINK-39605][Flink-Formats] Add avro variant confluent format [flink] via GitHub
• 2026/06/17 [jira] [Commented] (FLINK-39937) Merge jobmanager and taskmanager into the same JVM Robert Metzger (Jira)
• 2026/06/17 Re: [PR] [FLINK-39941][tests] Drop Python 3.8 from the flink-python tox envlist [flink-connector-kafka] via GitHub
• 2026/06/17 Re: [I] [Feature] Support auto resolve memory reference for passing data across actions. [flink-agents] via GitHub
• 2026/06/17 Re: [PR] [FLINK-39605][Flink-Formats] Add avro variant confluent format [flink] via GitHub
• 2026/06/17 Re: [PR] [FLINK-39637][state] Add filter pushdown support for savepoint connector [flink] via GitHub
• 2026/06/17 [jira] [Updated] (FLINK-39887) Use validated query node as a fallback when parsing the raw asQuery fails Ramin Gharib (Jira)
• 2026/06/17 [jira] [Commented] (FLINK-39887) Use validated query node as a fallback when parsing the raw asQuery fails Ramin Gharib (Jira)
• 2026/06/17 Re: [PR] [FLINK-39605][Flink-Formats] Add avro variant confluent format [flink] via GitHub
• 2026/06/17 Re: [PR] [FLINK-39605][Flink-Formats] Add avro variant confluent format [flink] via GitHub
• 2026/06/17 [jira] [Closed] (FLINK-39390) Add Extensibility to Autoscaler Components via the Plugin Mechanism Dennis-Mircea Ciupitu (Jira)
• 2026/06/17 Re: [PR] [FLINK-38918][PyFlink] Support per cluster offset for DynamicKafkaSource in pyflink [flink] via GitHub
• 2026/06/17 Re: [PR] [FLINK-39605][Flink-Formats] Add avro variant confluent format [flink] via GitHub
• 2026/06/17 Re: [PR] [Flink-39911][historyserver] Support Pluggable Storage Backend for HistoryServer [flink] via GitHub
• 2026/06/17 Re: [PR] [FLINK-39605][Flink-Formats] Add avro variant confluent format [flink] via GitHub
• 2026/06/17 Re: [PR] [FLINK-36235][Stream] Ignore emitting null rowData when deserialized message fails [flink-connector-pulsar] via GitHub
• 2026/06/17 Re: [PR] [FLINK-39913][table] Improve the error message when a foreground query emits an upsert changelog [flink] via GitHub
• 2026/06/17 Re: [PR] [FLINK-39511] FLIP-514: Custom Evaluator plugin for Flink Autoscaler [flink-kubernetes-operator] via GitHub
• 2026/06/17 Re: [D] Community Sync - 2026 [flink-agents] via GitHub
• 2026/06/17 Re: [PR] [FLINK-38733] Add new SplitterEnumerator on JdbcSource [flink-connector-jdbc] via GitHub
• 2026/06/17 Re: [PR] [FLINK-38733] Add new SplitterEnumerator on JdbcSource [flink-connector-jdbc] via GitHub
• 2026/06/17 Re: [PR] [FLINK-38733] Add new SplitterEnumerator on JdbcSource [flink-connector-jdbc] via GitHub
• 2026/06/17 [jira] [Commented] (FLINK-39330) FileSourceTextLinesITCase.testBoundedTextFileSourceWithJobManagerFailove fails Abhijeet Sharma (Jira)
• 2026/06/17 [jira] [Updated] (FLINK-39327) gauss dws pipeline sink connector ASF GitHub Bot (Jira)
• 2026/06/17 Re: [PR] [FLINK-39327][pipeline-connector/dws]add dws sink pipeline connector [flink-cdc] via GitHub
• 2026/06/17 Re: [PR] [FLINK-39330][runtime] Make CollectSinkFunction teardown null-safe to fix flaky FileSourceTextLinesITCase JM failover [flink] via GitHub
• 2026/06/17 Re: [PR] [FLINK-39511] FLIP-514: Custom Evaluator plugin for Flink Autoscaler [flink-kubernetes-operator] via GitHub
• 2026/06/17 Re: [PR] [FLINK-39511] FLIP-514: Custom Evaluator plugin for Flink Autoscaler [flink-kubernetes-operator] via GitHub
• 2026/06/17 Re: [I] [Umbrella] Release Flink Agents 0.3.0 [flink-agents] via GitHub
• 2026/06/17 Re: [I] [Feature] Support auto resolve memory reference for passing data across actions. [flink-agents] via GitHub
• 2026/06/17 Re: [PR] [FLINK-39948][planner] Fix compile issue in jdk11 for table-planner [flink] via GitHub
• 2026/06/17 [jira] [Resolved] (FLINK-39948) The flink-table-planner module failed to compile with JDK 11 Sergey Nuyanzin (Jira)
• 2026/06/17 [jira] [Commented] (FLINK-39948) The flink-table-planner module failed to compile with JDK 11 Sergey Nuyanzin (Jira)
• 2026/06/17 Re: [I] [Release] Prepare release announcement for Flink Agents 0.3.0 [flink-agents] via GitHub
• 2026/06/17 Re: [I] [Release] Prepare release announcement for Flink Agents 0.3.0 [flink-agents] via GitHub
• 2026/06/17 Re: [PR] [FLINK-39948][planner] Fix compile issue in jdk11 for table-planner [flink] via GitHub
• 2026/06/17 Re: [PR] [FLINK-39330][runtime] Make CollectSinkFunction teardown null-safe to fix flaky FileSourceTextLinesITCase JM failover [flink] via GitHub
• 2026/06/17 Re: [PR] [FLINK-39330][runtime] Make CollectSinkFunction teardown null-safe to fix flaky FileSourceTextLinesITCase JM failover [flink] via GitHub
• 2026/06/17 [jira] [Updated] (FLINK-39330) FileSourceTextLinesITCase.testBoundedTextFileSourceWithJobManagerFailove fails ASF GitHub Bot (Jira)
• 2026/06/17 [PR] [FLINK-39330][runtime] Make CollectSinkFunction teardown null-safe to fix flaky FileSourceTextLinesITCase JM failover [flink] via GitHub
• 2026/06/17 Re: [PR] [FLINK-39767][tests][JUnit5 migration] Module: flink-statebackend-forst [flink] via GitHub
• 2026/06/17 [jira] [Assigned] (FLINK-39925) Job throughput metrics incorrectly dropping to zero, forcing scale down Robert Metzger (Jira)
• 2026/06/17 [jira] [Updated] (FLINK-39944) Dynamic Kafka source cluster removal is not resilient enough Robert Metzger (Jira)
• 2026/06/17 [jira] [Assigned] (FLINK-39330) FileSourceTextLinesITCase.testBoundedTextFileSourceWithJobManagerFailove fails Robert Metzger (Jira)
• 2026/06/17 Re: [PR] [FLINK-39732] Introduce TableDiscoverer SPI for flexible table subscription (with default JdbcTableDiscoverer) [flink-cdc] via GitHub
• 2026/06/17 Re: [PR] [Flink-39911][historyserver] Support Pluggable Storage Backend for HistoryServer [flink] via GitHub
• 2026/06/17 Re: [PR] [FLINK-39732] Introduce TableDiscoverer SPI for flexible table subscription (with default JdbcTableDiscoverer) [flink-cdc] via GitHub
• 2026/06/17 Re: [PR] [FLINK-39732] Introduce TableDiscoverer SPI for flexible table subscription (with default JdbcTableDiscoverer) [flink-cdc] via GitHub
• 2026/06/17 Re: [PR] [FLINK-39511] FLIP-514: Custom Evaluator plugin for Flink Autoscaler [flink-kubernetes-operator] via GitHub
• 2026/06/17 Re: [PR] [FLINK-39511] FLIP-514: Custom Evaluator plugin for Flink Autoscaler [flink-kubernetes-operator] via GitHub
• 2026/06/17 Re: [PR] [FLINK-39511] FLIP-514: Custom Evaluator plugin for Flink Autoscaler [flink-kubernetes-operator] via GitHub
• 2026/06/17 Re: [PR] [FLINK-39499][tests] Replace MinIO with SeaweedFS [flink] via GitHub
• 2026/06/17 [jira] [Updated] (FLINK-38997) Job can get stuck in state transition because unexpected error during ExecutionGraph creation ASF GitHub Bot (Jira)
• 2026/06/17 Re: [PR] [FLINK-38997] Fix StateTransitionManager stuck in Transitioning phase on failed transition [flink] via GitHub
• 2026/06/17 Re: [PR] Add release automation scripts (Phase A) [flink] via GitHub
• 2026/06/17 Re: [PR] Add release automation scripts (Phase A) [flink] via GitHub
• 2026/06/17 Re: [PR] [FLINK-28440][changelog] Fix premature discard of state handles during checkpoint restore [flink] via GitHub
• 2026/06/17 Re: [PR] [FLINK-28440][changelog] Fix premature discard of state handles during checkpoint restore [flink] via GitHub
• 2026/06/17 Re: [PR] [FLINK-36744][docs] Document operator's FlinkVersion compatibility policy [flink-kubernetes-operator] via GitHub
• 2026/06/17 Re: [PR] [FLINK-39837] Retain removed dynamic Kafka cluster offsets [flink-connector-kafka] via GitHub
• 2026/06/17 [jira] [Updated] (FLINK-39950) [sqlserver] scan.incremental.snapshot.chunk.key-column only searches primary key columns instead of all table columns ASF GitHub Bot (Jira)
• 2026/06/17 [PR] [FLINK-39950][sqlserver] Fix chunk key column search restricted to primary key columns [flink-cdc] via GitHub
• 2026/06/17 [jira] [Commented] (FLINK-36744) Document operator's FlinkVersion compatibility Arvind Kandpal (Jira)
• 2026/06/17 Re: [PR] [FLINK-36744][docs] Document operator's FlinkVersion compatibility policy [flink-kubernetes-operator] via GitHub

• Earlier messages
• Later messages