issues  

Messages by Date

• 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
• 2026/06/17 Re: [PR] [FLINK-39951][python] Fix string reference equality bug in ArrayConstructor causing silent long value truncation [flink] via GitHub
• 2026/06/17 [jira] [Updated] (FLINK-36744) Document operator's FlinkVersion compatibility ASF GitHub Bot (Jira)
• 2026/06/17 [PR] [FLINK-36744][docs] Document operator's FlinkVersion compatibility policy [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-39824][mysql] Cache table filter results to reduce regex matching [flink-cdc] via GitHub
• 2026/06/17 Re: [PR] [FLINK-39824][mysql] Cache table filter results to reduce regex matching [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 [jira] [Updated] (FLINK-39951) [Python] ArrayConstructor uses == for String comparison, silently truncating long array values to int ASF GitHub Bot (Jira)
• 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 [PR] [FLINK-39951][python] Fix string reference equality bug in ArrayConstructor causing silent long value truncation [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-39824][mysql] Cache table filter results to reduce regex matching [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-39824][mysql] Cache table filter results to reduce regex matching [flink-cdc] via GitHub
• 2026/06/17 Re: [PR] [FLINK-39824][mysql] Cache table filter results to reduce regex matching [flink-cdc] via GitHub
• 2026/06/17 [jira] [Created] (FLINK-39951) [Python] ArrayConstructor uses == for String comparison, silently truncating long array values to int Jubin Soni (Jira)
• 2026/06/17 [PR] feat: add flink-stock-trading-demo — intelligent stock trading analysis system [flink-agents-demos] via GitHub
• 2026/06/17 [jira] [Commented] (FLINK-36744) Document operator's FlinkVersion compatibility Arvind Kandpal (Jira)
• 2026/06/17 [jira] [Commented] (FLINK-39950) [sqlserver] scan.incremental.snapshot.chunk.key-column only searches primary key columns instead of all table columns Jubin Soni (Jira)
• 2026/06/17 [jira] [Created] (FLINK-39950) [sqlserver] scan.incremental.snapshot.chunk.key-column only searches primary key columns instead of all table columns Jubin Soni (Jira)
• 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-39949][state/forst] Implement full snapshot restore for ForSt state backend [flink] via GitHub
• 2026/06/17 [jira] [Updated] (FLINK-39949) [ForSt] State restore from savepoints/checkpoints not supported ASF GitHub Bot (Jira)
• 2026/06/17 [PR] [FLINK-39949][state/forst] Implement full snapshot restore for ForSt state backend [flink] via GitHub
• 2026/06/17 Re: [PR] [FLINK-39881] Add generative AI tooling disclosure section to PR template [flink-kubernetes-operator] via GitHub
• 2026/06/17 Re: [PR] [FLINK-39853][test] Upgrade Testcontainers to 2.0.5 and remove JUnit 4 dependency [flink-kubernetes-operator] via GitHub
• 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 [jira] [Commented] (FLINK-39949) [ForSt] State restore from savepoints/checkpoints not supported Jubin Soni (Jira)
• 2026/06/17 [jira] [Created] (FLINK-39949) [ForSt] State restore from savepoints/checkpoints not supported Jubin Soni (Jira)
• 2026/06/17 [jira] [Updated] (FLINK-39925) Job throughput metrics incorrectly dropping to zero, forcing scale down ASF GitHub Bot (Jira)
• 2026/06/17 Re: [PR] [FLINK-37663][connector-base] Fix lost wakeup in FutureCompletingBlockingQueue [flink] via GitHub
• 2026/06/17 [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/16 Re: [PR] [FLINK-39824][mysql] Cache table filter results to reduce regex matching [flink-cdc] via GitHub
• 2026/06/16 Re: [PR] [BP-1.20][FLINK-37663][connector-base] Fix lost wakeup in FutureCompletingBlockingQueue [flink] via GitHub
• 2026/06/16 Re: [PR] [BP-2.0][FLINK-37663][connector-base] Fix lost wakeup in FutureCompletingBlockingQueue [flink] via GitHub
• 2026/06/16 Re: [PR] [BP-2.1][FLINK-37663][connector-base] Fix lost wakeup in FutureCompletingBlockingQueue [flink] via GitHub
• 2026/06/16 Re: [PR] [BP-2.2][FLINK-37663][connector-base] Fix lost wakeup in FutureCompletingBlockingQueue [flink] via GitHub
• 2026/06/16 Re: [PR] [BP-2.3][FLINK-37663][connector-base] Fix lost wakeup in FutureCompletingBlockingQueue [flink] via GitHub
• 2026/06/16 [PR] [BP-2.3][FLINK-37663][connector-base] Fix lost wakeup in FutureCompletingBlockingQueue [flink] via GitHub
• 2026/06/16 [PR] [BP-1.20][FLINK-37663][connector-base] Fix lost wakeup in FutureCompletingBlockingQueue [flink] via GitHub
• 2026/06/16 [PR] [BP-2.0][FLINK-37663][connector-base] Fix lost wakeup in FutureCompletingBlockingQueue [flink] via GitHub
• 2026/06/16 [PR] [BP-2.1][FLINK-37663][connector-base] Fix lost wakeup in FutureCompletingBlockingQueue [flink] via GitHub
• 2026/06/16 [PR] [BP-2.2][FLINK-37663][connector-base] Fix lost wakeup in FutureCompletingBlockingQueue [flink] via GitHub
• 2026/06/16 Re: [PR] [FLINK-38918][PyFlink] Support per cluster offset for DynamicKafkaSource in pyflink [flink] via GitHub
• 2026/06/16 [jira] [Commented] (FLINK-13680) Translate "Code Style - Common Rules" page into Chinese Nuozheng (Jira)
• 2026/06/16 Re: [PR] [FLINK-38144][state] Fix changelog state backend NPE with null map state values [flink] via GitHub
• 2026/06/16 Re: [PR] [FLINK-39875][table-gateway] Restore thread interrupt status in ResultStore [flink] via GitHub
• 2026/06/16 [jira] [Closed] (FLINK-39743) Incorrect Expected Processing Rate Computation Gyula Fora (Jira)
• 2026/06/16 Re: [PR] [FLINK-39873][streaming] Add null check for `connectedSocket` in `SocketStreamIterator.notifyOfError()` [flink] via GitHub
• 2026/06/16 Re: [PR] [FLINK-39873][streaming] Add null check for `connectedSocket` in `SocketStreamIterator.notifyOfError()` [flink] via GitHub
• 2026/06/16 Re: [PR] [FLINK-39743] [flink-autoscaler] Fix incorrect expected processing rate computation [flink-kubernetes-operator] via GitHub
• 2026/06/16 Re: [PR] [FLINK-39715] [table-planner] Fix IndexOutOfBoundsException in FlinkExpandConversionRule for global aggregate after sort [flink] via GitHub
• 2026/06/16 Re: [PR] [FLINK-39730][runtime] Honor maxExceptions on ApplicationExceptionsHandler [flink] via GitHub
• 2026/06/16 Re: [PR] [FLINK-39948][planner] Fix compile issue in jdk11 for table-planner [flink] via GitHub
• 2026/06/16 Re: [PR] [FLINK-39743] [flink-autoscaler] Fix incorrect expected processing rate computation [flink-kubernetes-operator] via GitHub
• 2026/06/16 Re: [PR] [FLINK-39791][helm] Honor defaultConfiguration.config.yaml and always mount config.yaml [flink-kubernetes-operator] via GitHub
• 2026/06/16 Re: [PR] [FLINK-39511] FLIP-514: Custom Evaluator plugin for Flink Autoscaler [flink-kubernetes-operator] via GitHub
• 2026/06/16 [jira] [Comment Edited] (FLINK-38943) Support Adaptive Partition Selection for RescalePartitioner & RebalancePartitioner Yuepeng Pan (Jira)
• 2026/06/16 [jira] [Updated] (FLINK-38943) Support Adaptive Partition Selection for RescalePartitioner & RebalancePartitioner Yuepeng Pan (Jira)
• 2026/06/16 [jira] [Updated] (FLINK-36744) Document operator's FlinkVersion compatibility Gyula Fora (Jira)
• 2026/06/16 [jira] [Updated] (FLINK-36418) Update Control Flow page with latest developments Gyula Fora (Jira)
• 2026/06/16 [jira] [Closed] (FLINK-31857) Support pluginable observers mechanism Gyula Fora (Jira)
• 2026/06/16 [jira] [Closed] (FLINK-30638) Operator doesn't forward allowNonRestoredState flag Gyula Fora (Jira)
• 2026/06/16 [jira] [Closed] (FLINK-33131) Grafana dashboard for flink k8 operator metrics Gyula Fora (Jira)
• 2026/06/16 [jira] [Assigned] (FLINK-39673) SQL jobs may ignore user-configured claim mode with deprecated config key lincoln lee (Jira)
• 2026/06/16 [jira] [Closed] (FLINK-36528) Update org.apache.avro : avro dependency Gyula Fora (Jira)
• 2026/06/16 [jira] [Closed] (FLINK-34441) Add Documentation for flink-sql-runner-example in Kubernetes Operator Documentation Gyula Fora (Jira)
• 2026/06/16 [jira] [Closed] (FLINK-36169) Support namespace level resource check before scaling up Gyula Fora (Jira)
• 2026/06/16 Re: [PR] [FLINK-36973][config] Skip options not explicitly set when converting SavepointRestoreSettings to Configuration [flink] via GitHub
• 2026/06/16 [jira] [Closed] (FLINK-36932) Add resource-level metrics for different status/states to flink-kubernetes-operator Gyula Fora (Jira)
• 2026/06/16 [jira] [Closed] (FLINK-36557) Stale Autoscaler Context in Kubernetes Operator Gyula Fora (Jira)
• 2026/06/16 [jira] [Updated] (FLINK-37911) [Helm] Reorganize Helm chart templates Gyula Fora (Jira)
• 2026/06/16 [jira] [Closed] (FLINK-38283) Support customized autoscaling algorithm Gyula Fora (Jira)
• 2026/06/16 [jira] [Closed] (FLINK-37911) [Helm] Reorganize Helm chart templates Gyula Fora (Jira)
• 2026/06/16 Re: [PR] [FLINK-39948][planner] Fix compile issue in jdk11 for table-planner [flink] via GitHub
• 2026/06/16 [jira] [Closed] (FLINK-39271) Harden session job deletion flow Gyula Fora (Jira)
• 2026/06/16 [jira] [Closed] (FLINK-39805) FlinkConfigBuilder uses platform-default charset when writing log/pod-template files Gyula Fora (Jira)
• 2026/06/16 [jira] [Closed] (FLINK-38409) Showcase in Helm chart values.yaml that config.yaml can be used Gyula Fora (Jira)
• 2026/06/16 [jira] [Commented] (FLINK-38825) Introduce an AI-friendly Async Batch Operator for high-latency inference workloads Shengkai Fang (Jira)
• 2026/06/16 [jira] [Updated] (FLINK-39948) The flink-table-planner module failed to compile with JDK 11 ASF GitHub Bot (Jira)
• 2026/06/16 [PR] [FLINK-39948][planner] Fix compile issue in jdk11 for table-planner [flink] via GitHub
• 2026/06/16 [jira] [Created] (FLINK-39948) The flink-table-planner module failed to compile with JDK 11 reswqa (Jira)
• 2026/06/16 [jira] [Updated] (FLINK-38943) Support Adaptive Partition Selection for RescalePartitioner & RebalancePartitioner Yuepeng Pan (Jira)
• 2026/06/16 [jira] [Updated] (FLINK-38943) Support Adaptive Partition Selection for RescalePartitioner & RebalancePartitioner Yuepeng Pan (Jira)
• 2026/06/16 [jira] [Comment Edited] (FLINK-38943) Support Adaptive Partition Selection for RescalePartitioner & RebalancePartitioner Yuepeng Pan (Jira)
• 2026/06/16 Re: [PR] [BP-2.3][hotfix][runtime] Avoid duplicate serialization in adaptive broadcast [flink] via GitHub
• 2026/06/16 Re: [PR] [FLINK-39572] [python] Hide sensitive process environment values in logs [flink] via GitHub
• 2026/06/16 Re: [PR] [FLINK-38046][Connector/JDBC]Solve the issue of missing one piece of data [flink-connector-jdbc] via GitHub
• 2026/06/16 Re: [PR] [FLINK-36794] [cdc-composer/cli] pipeline cdc connector support multiple data sources [flink-cdc] via GitHub
• 2026/06/16 Re: [PR] [FLINK-36794] [cdc-composer/cli] pipeline cdc connector support multiple data sources [flink-cdc] via GitHub
• 2026/06/16 Re: [PR] [api][routing] Pluggable in-chat LLM routing (ChatModelRouter + RoutingStrategy) [flink-agents] via GitHub
• 2026/06/16 Re: [PR] [FLINK-38918][PyFlink] Support per cluster offset for DynamicKafkaSource in pyflink [flink] via GitHub
• 2026/06/16 Re: [PR] [FLINK-29984][flink-metrics] Export Prometheus histogram min and max [flink] via GitHub
• 2026/06/16 [PR] [FLINK-29984][flink-metrics] Export Prometheus histogram min and max [flink] via GitHub
• 2026/06/16 Re: [PR] [FLINK-38918][PyFlink] Support per cluster offset for DynamicKafkaSource in pyflink [flink] via GitHub
• 2026/06/16 Re: [PR] [FLINK-29984][flink-metrics] Export Prometheus histogram min and max [flink] via GitHub
• 2026/06/16 Re: [PR] [FLINK-29984][flink-metrics] Export Prometheus histogram min and max [flink] via GitHub
• 2026/06/16 [PR] [FLINK-29984][flink-metrics] Export Prometheus histogram min and max [flink] via GitHub
• 2026/06/16 Re: [PR] [FLINK-39499][tests] Replace MinIO with SeaweedFS [flink] via GitHub
• 2026/06/16 Re: [PR] [FLINK-39888][Kafka] Allow configuring offset reset strategy independently [flink-connector-kafka] via GitHub
• 2026/06/16 Re: [PR] [FLINK-39499][tests] Replace MinIO with SeaweedFS [flink] via GitHub
• 2026/06/16 Re: [PR] [FLINK-39499][tests] Replace MinIO with SeaweedFS [flink] via GitHub
• 2026/06/16 Re: [PR] [FLINK-35562][table-planner] Bound result wait in RestoreTestBase to avoid CI hangs [flink] via GitHub
• 2026/06/16 Re: [PR] [FLINK-39888][Kafka] Allow configuring offset reset strategy independently [flink-connector-kafka] via GitHub
• 2026/06/16 Re: [PR] [FLINK-38918][PyFlink] Support per cluster offset for DynamicKafkaSource in pyflink [flink] via GitHub
• 2026/06/16 [jira] [Commented] (FLINK-38614) SinkV2ITCase.writerAndCommitterExecuteInStreamingModeWithScaling failed in test_cron_adaptive_scheduler tests Martijn Visser (Jira)
• 2026/06/16 [jira] [Reopened] (FLINK-38614) SinkV2ITCase.writerAndCommitterExecuteInStreamingModeWithScaling failed in test_cron_adaptive_scheduler tests Martijn Visser (Jira)
• 2026/06/16 [jira] [Commented] (FLINK-37663) Thread Synchronization Issue in FutureCompletingBlockingQueue <> Connector Split Fetching Herbert Wang (Jira)
• 2026/06/16 [jira] [Updated] (FLINK-37663) Thread Synchronization Issue in FutureCompletingBlockingQueue <> Connector Split Fetching Martijn Visser (Jira)
• 2026/06/16 [jira] [Assigned] (FLINK-37663) Thread Synchronization Issue in FutureCompletingBlockingQueue <> Connector Split Fetching Martijn Visser (Jira)
• 2026/06/16 [jira] [Commented] (FLINK-37663) Thread Synchronization Issue in FutureCompletingBlockingQueue <> Connector Split Fetching Martijn Visser (Jira)
• 2026/06/16 Re: [PR] [FLINK-37663][connector-base] Fix lost wakeup in FutureCompletingBlockingQueue [flink] via GitHub
• 2026/06/16 [PR] [FLINK-37663][connector-base] Fix lost wakeup in FutureCompletingBlockingQueue [flink] via GitHub
• 2026/06/16 [jira] [Commented] (FLINK-39122) Decimals with incorrect precision lead to null value in PTF Timo Walther (Jira)
• 2026/06/16 [jira] [Closed] (FLINK-39882) Parser can not parse unparsed polymorphic table functions with several table args Timo Walther (Jira)
• 2026/06/16 [jira] [Closed] (FLINK-37700) SQL parse exception when creating a view with PTF Timo Walther (Jira)
• 2026/06/16 Re: [PR] [BP-2.3][hotfix][runtime] Avoid duplicate serialization in adaptive broadcast [flink] via GitHub
• 2026/06/16 [jira] [Commented] (FLINK-39615) Translate documentation in changelog.md to chinese Arvind Kandpal (Jira)
• 2026/06/16 Re: [PR] [FLINK-39679] Fixes PTF implicit argument casting for basic types [flink] via GitHub
• 2026/06/16 Re: [PR] [FLINK-39679] Fixes PTF implicit argument casting for basic types [flink] via GitHub
• 2026/06/16 [jira] [Closed] (FLINK-39679) Implicit type conversion fails in code gen Timo Walther (Jira)
• 2026/06/16 Re: [PR] [release-2.3][FLINK-39679][table-planner] Fix implicit casts for PTF calls [flink] via GitHub
• 2026/06/16 [jira] [Created] (FLINK-39947) Fix the flaky test case in class TaskExecutorPartitionLifecycleTest Yuepeng Pan (Jira)
• 2026/06/16 [jira] [Commented] (FLINK-39936) Add flink-s3-fs-native to flink-dist pom file Yuepeng Pan (Jira)
• 2026/06/16 Re: [PR] [FLINK-39936][dist] Add flink-s3-fs-native to flink-dist pom file [flink] via GitHub
• 2026/06/16 Re: [PR] [hotfix][build] Bump netty to 4.2.15.Final [flink] via GitHub
• 2026/06/16 Re: [PR] [FLINK-39936][dist] Add flink-s3-fs-native to flink-dist pom file [flink] via GitHub
• 2026/06/16 Re: [PR] Bump launch-editor from 2.11.0 to 2.14.1 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/06/16 Re: [PR] Bump js-yaml from 4.1.0 to 4.2.0 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/06/16 [jira] [Resolved] (FLINK-36602) Upgrade Calcite version to 1.38.0 Sergey Nuyanzin (Jira)
• 2026/06/16 [jira] [Commented] (FLINK-36602) Upgrade Calcite version to 1.38.0 Sergey Nuyanzin (Jira)
• 2026/06/16 [PR] Bump js-yaml from 4.1.0 to 4.2.0 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/06/16 [PR] Bump launch-editor from 2.11.0 to 2.14.1 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/06/16 Re: [PR] [FLINK-36602][table] Upgrade Calcite version to 1.38.0 [flink] via GitHub
• 2026/06/16 Re: [PR] Add HTTP Connector 1.0 [flink-web] via GitHub
• 2026/06/16 Re: [PR] Add HTTP Connector 1.0 [flink-web] via GitHub
• 2026/06/16 Re: [PR] [FLINK-39889][table] Thread USING CONNECTION clause into CatalogTable and CreateTableOperation [flink] via GitHub
• 2026/06/16 Re: [PR] [FLINK-38948][docs] Document SINGLE_VALUE aggregate function [flink] via GitHub
• 2026/06/16 Re: [PR] Add HTTP Connector 1.0 [flink-web] via GitHub
• 2026/06/16 Re: [D] Flink Agents Release Process [flink-agents] via GitHub
• 2026/06/16 Re: [PR] Add HTTP Connector 1.0 [flink-web] via GitHub
• 2026/06/16 Re: [PR] [release-2.3][FLINK-39679][table-planner] Fix implicit casts for PTF calls [flink] via GitHub
• 2026/06/16 [jira] [Commented] (FLINK-39615) Translate documentation in changelog.md to chinese Gustavo de Morais (Jira)
• 2026/06/16 Re: [PR] Add HTTP Connector 1.0 [flink-web] via GitHub

• Earlier messages
• Later messages