issues
Thread
Date
Earlier messages
Later messages
Messages by Date
2026/06/20
Re: [PR] [FLINK-39898][runtime] Fire processing-time timers between unaligned checkpoints when mini-batch is enabled [flink]
via GitHub
2026/06/20
Re: [PR] [FLINK-39898][runtime] Fire processing-time timers between unaligned checkpoints when mini-batch is enabled [flink]
via GitHub
2026/06/20
Re: [PR] [FLINK-20454][formats] Add metadata support for Debezium Avro [flink]
via GitHub
2026/06/20
[jira] [Updated] (FLINK-39961) Support routing across models in Flink SQL (ML_PREDICT)
Purshotam Shah (Jira)
2026/06/20
[jira] [Created] (FLINK-39961) Support routing across models in Flink SQL (ML_PREDICT)
Purshotam Shah (Jira)
2026/06/20
Re: [PR] [FLINK-20454][formats] Add metadata support for Debezium Avro [flink]
via GitHub
2026/06/20
Re: [PR] [FLINK-39715] [table-planner] Fix IndexOutOfBoundsException in FlinkExpandConversionRule for global aggregate after sort [flink]
via GitHub
2026/06/20
Re: [PR] [FLINK-39898][runtime] Fire processing-time timers between unaligned checkpoints when mini-batch is enabled [flink]
via GitHub
2026/06/20
Re: [PR] [FLINK-39715] [table-planner] Fix IndexOutOfBoundsException in FlinkExpandConversionRule for global aggregate after sort [flink]
via GitHub
2026/06/20
Re: [PR] [FLINK-23140][docs] Fix SourceFunction documentation link [flink]
via GitHub
2026/06/20
Re: [PR] [FLINK-23140][docs] Fix SourceFunction documentation link [flink]
via GitHub
2026/06/20
Re: [PR] [hotfix][runtime-web] Restyle Cancel Job/Application action as a danger button [flink]
via GitHub
2026/06/20
[PR] [hotfix][runtime-web] Restyle Cancel Job/Application action as a danger button [flink]
via GitHub
2026/06/20
Re: [PR] [hotfix] warning for conditional [flink]
via GitHub
2026/06/20
[jira] [Updated] (FLINK-39566) [runtime-web] Add checkpoint duration Gantt view
Purushottam Sinha (Jira)
2026/06/20
Re: [PR] [FLINK-37834] Flink JDBC support ClickHouse Dialect [flink-connector-jdbc]
via GitHub
2026/06/20
Re: [PR] [FLINK-39960][docs] Remove broken JavaDoc shortcode usage from JDBC docs [flink-connector-jdbc]
via GitHub
2026/06/20
[jira] [Updated] (FLINK-39960) Remove broken JavaDoc shortcode usage from JDBC datastream docs
ASF GitHub Bot (Jira)
2026/06/20
[jira] [Created] (FLINK-39960) Remove broken JavaDoc shortcode usage from JDBC datastream docs
Dennis-Mircea Ciupitu (Jira)
2026/06/20
Re: [PR] [FLINK-37834] Flink JDBC support ClickHouse Dialect [flink-connector-jdbc]
via GitHub
2026/06/20
Re: [PR] [FLINK-38046][Connector/JDBC]Solve the issue of missing one piece of data [flink-connector-jdbc]
via GitHub
2026/06/20
Re: [PR] [hotfix] Stabilize integration test (derby) [flink-connector-jdbc]
via GitHub
2026/06/20
Re: [PR] [FLINK-37834] Flink JDBC support ClickHouse Dialect [flink-connector-jdbc]
via GitHub
2026/06/20
Re: [PR] [FLINK-37834] Flink JDBC support ClickHouse Dialect [flink-connector-jdbc]
via GitHub
2026/06/20
Re: [PR] [FLINK-20454][formats] Add metadata support for Debezium Avro [flink]
via GitHub
2026/06/20
Re: [PR] [FLINK-38046][Connector/JDBC]Solve the issue of missing one piece of data [flink-connector-jdbc]
via GitHub
2026/06/20
[PR] [FLINK-20454][formats] Add metadata support for Debezium Avro [flink]
via GitHub
2026/06/20
Re: [PR] [FLINK-37834] Flink JDBC support ClickHouse Dialect [flink-connector-jdbc]
via GitHub
2026/06/20
Re: [PR] [FLINK-37834] Flink JDBC support ClickHouse Dialect [flink-connector-jdbc]
via GitHub
2026/06/20
Re: [PR] [FLINK-39899] Fix Flink SQL rowtime attributes after Window TVF [flink]
via GitHub
2026/06/20
Re: [PR] [FLINK-39881] Add AGENTS.md and generative AI tooling disclosure to PR template [flink-kubernetes-operator]
via GitHub
2026/06/20
[jira] [Updated] (FLINK-39881) [FKO] Adopt AI-assisted contribution guidelines for the Kubernetes Operator
Purushottam Sinha (Jira)
2026/06/20
[jira] [Updated] (FLINK-39881) [FKO] Add AI tooling disclosure section to the PR template
Purushottam Sinha (Jira)
2026/06/20
Re: [PR] [FLINK-37834] Flink JDBC support ClickHouse Dialect [flink-connector-jdbc]
via GitHub
2026/06/20
Re: [PR] [FLINK-39772][tests][JUnit5 migration] Module: flink-fs-tests [flink]
via GitHub
2026/06/20
Re: [PR] [FLINK-39772][tests][JUnit5 migration] Module: flink-fs-tests [flink]
via GitHub
2026/06/20
[jira] [Updated] (FLINK-39772) [JUnit5 Migration] Module: flink-fs-tests
ASF GitHub Bot (Jira)
2026/06/20
[PR] [FLINK-39772][tests][JUnit5 migration] Module: flink-fs-tests [flink]
via GitHub
2026/06/20
Re: [PR] [hotfix][build] Bump netty to 4.2.15.Final [flink]
via GitHub
2026/06/20
Re: [PR] [FLINK-39769][tests][JUnit5 migration] Module: flink-examples-streaming [flink]
via GitHub
2026/06/20
[jira] [Updated] (FLINK-39769) [JUnit5 Migration] Module: flink-examples-streaming
ASF GitHub Bot (Jira)
2026/06/20
[PR] [FLINK-39769][tests][JUnit5 migration] Module: flink-examples-streaming [flink]
via GitHub
2026/06/20
Re: [PR] [hotfix][docs] Fix broken and stale documentation links [flink]
via GitHub
2026/06/20
[PR] [hotfix][docs] Fix broken and stale documentation links [flink]
via GitHub
2026/06/20
Re: [PR] [hotfix][docs] Remove broken JavaDoc shortcode usage from JDBC docs [flink-connector-jdbc]
via GitHub
2026/06/20
Re: [PR] [FLINK-37834] Flink JDBC support ClickHouse Dialect [flink-connector-jdbc]
via GitHub
2026/06/20
Re: [PR] [FLINK-39931] Fix flaky AdaptiveBatchSchedulerTest due to unexpected ComponentMainThreadExecutor behavior in async execution [flink]
via GitHub
2026/06/20
Re: [PR] [FLINK-39923][state] Fix RocksDB Statistics native memory leak [flink]
via GitHub
2026/06/20
Re: [PR] [FLINK-39923][state] Fix RocksDB Statistics native memory leak [flink]
via GitHub
2026/06/20
Re: [PR] [FLINK-39923][state] Fix RocksDB Statistics native memory leak [flink]
via GitHub
2026/06/20
Re: [PR] [FLINK-39923][state] Fix RocksDB Statistics native memory leak [flink]
via GitHub
2026/06/20
[jira] [Resolved] (FLINK-39670) Bump Flink-controlled Java dependencies to resolve CVEs Part 2 (kafka-clients, okhttp, wiremock)
Sergey Nuyanzin (Jira)
2026/06/20
[jira] [Commented] (FLINK-39670) Bump Flink-controlled Java dependencies to resolve CVEs Part 2 (kafka-clients, okhttp, wiremock)
Sergey Nuyanzin (Jira)
2026/06/20
Re: [PR] [FLINK-39670][build] Update test-scope dependencies (kafka-clients, okhttp, wiremock) [flink]
via GitHub
2026/06/20
Re: [PR] [hotfix][docs] Remove broken JavaDoc shortcode usage from JDBC docs [flink-connector-jdbc]
via GitHub
2026/06/20
Re: [PR] [hotfix][docs] Remove broken JavaDoc shortcode usage from JDBC docs [flink-connector-jdbc]
via GitHub
2026/06/20
Re: [PR] [hotfix][docs] Remove broken JavaDoc shortcode usage from JDBC docs [flink-connector-jdbc]
via GitHub
2026/06/20
[jira] [Commented] (FLINK-39767) [JUnit5 Migration] Module: flink-statebackend-forst
Sergey Nuyanzin (Jira)
2026/06/20
[jira] [Resolved] (FLINK-39767) [JUnit5 Migration] Module: flink-statebackend-forst
Sergey Nuyanzin (Jira)
2026/06/20
Re: [PR] [FLINK-39767][tests][JUnit5 migration] Module: flink-statebackend-forst [flink]
via GitHub
2026/06/20
Re: [PR] [hotfix] [metrics] Document boolean parsing and extend MetricConfigTest [flink]
via GitHub
2026/06/20
Re: [PR] [hotfix] [runtime/tests] Wait for clock advance in BlobServerCleanupTest [flink]
via GitHub
2026/06/20
Re: [PR] [FLINK-39931] Fix flaky AdaptiveBatchSchedulerTest due to unexpected ComponentMainThreadExecutor behavior in async execution [flink]
via GitHub
2026/06/19
Re: [PR] [FLINK-39491][runtime] move lineage Listener creation to Dispatcher [flink]
via GitHub
2026/06/19
[jira] [Commented] (FLINK-35324) Avro format can not perform projection pushdown for specific fields
Archit Goyal (Jira)
2026/06/19
Re: [PR] [FLINK-38046][Connector/JDBC]Solve the issue of missing one piece of data [flink-connector-jdbc]
via GitHub
2026/06/19
Re: [PR] [FLINK-23140][docs] Fix SourceFunction documentation link [flink]
via GitHub
2026/06/19
Re: [PR] FLIP-573: [DRAFT] Queues for Kafka [flink-connector-kafka]
via GitHub
2026/06/19
Re: [PR] FLIP-573: [DRAFT] Queues for Kafka [flink-connector-kafka]
via GitHub
2026/06/19
Re: [PR] [FLINK-23140][docs] Fix SourceFunction documentation link [flink]
via GitHub
2026/06/19
Re: [PR] FLIP-573: [DRAFT] Queues for Kafka [flink-connector-kafka]
via GitHub
2026/06/19
Re: [PR] FLIP-573: [DRAFT] Queues for Kafka [flink-connector-kafka]
via GitHub
2026/06/19
[PR] FLIP-573: [DRAFT] Queues for Kafka [flink-connector-kafka]
via GitHub
2026/06/19
Re: [PR] FLIP-573: [DRAFT] Queues for Kafka [flink-connector-kafka]
via GitHub
2026/06/19
Re: [PR] Native s3 Filesystem Blog [flink-web]
via GitHub
2026/06/19
Re: [PR] Native s3 Filesystem Blog [flink-web]
via GitHub
2026/06/19
Re: [PR] Native s3 Filesystem Blog [flink-web]
via GitHub
2026/06/19
[jira] [Resolved] (FLINK-39921) Fix the flaky test case ExecutionTimeBasedSlowTaskDetectorTest due to unexepected ComponentMainThreadExecutor setting.
Yuepeng Pan (Jira)
2026/06/19
Re: [PR] [FLINK-39929][runtime/tests] Fix the flaky test case ExecutionVertexCancelTest.testSendCancelAndReceiveFail [flink]
via GitHub
2026/06/19
Re: [PR] [FLINK-23882][docs] Clarify TIMESTAMP WITH TIME ZONE is not supported by Flink SQL [flink]
via GitHub
2026/06/19
Re: [PR] [FLINK-23140][docs] Fix SourceFunction documentation link [flink]
via GitHub
2026/06/19
Re: [PR] [FLINK-39788][kubernetes] Append .svc suffix to namespaced Kubernetes service hostnames [flink]
via GitHub
2026/06/19
[jira] [Updated] (FLINK-23140) Invalid link in Data Sources documentation
ASF GitHub Bot (Jira)
2026/06/19
[PR] [FLINK-23140][docs] Fix SourceFunction documentation link [flink]
via GitHub
2026/06/19
Re: [PR] [FLINK-23882][docs] Clarify TIMESTAMP WITH TIME ZONE is not supported by Flink SQL [flink]
via GitHub
2026/06/19
[jira] [Updated] (FLINK-39788) Pekko error "Actor not found" when Kubernetes namespace starts from digit
ASF GitHub Bot (Jira)
2026/06/19
[PR] [FLINK-39788][kubernetes] Append .svc suffix to namespaced Kubernetes service hostnames [flink]
via GitHub
2026/06/19
[jira] [Updated] (FLINK-23882) Documentation of TIMESTAMP WITH TIME ZONE should state that it is currently not supported by Flink SQL
ASF GitHub Bot (Jira)
2026/06/19
[PR] [FLINK-23882][docs] Clarify TIMESTAMP WITH TIME ZONE is not supported by Flink SQL [flink]
via GitHub
2026/06/19
Re: [PR] FLINK-39725: fix(python): apply timestamp assigner in from_source for pyflink [flink]
via GitHub
2026/06/19
[jira] [Updated] (FLINK-39725) from_source does not use timestamp assigner in pyflink
ASF GitHub Bot (Jira)
2026/06/19
[PR] FLINK-39725: fix(python): apply timestamp assigner in from_source for pyflink [flink]
via GitHub
2026/06/19
Re: [PR] FLINK-39724: fix(python): support InternalTypeInfo in _from_java_type [flink]
via GitHub
2026/06/19
[jira] [Updated] (FLINK-39724) CsvReaderFormat produces a stream which fails get_type() and assign_timestamps_and_watermarks()
ASF GitHub Bot (Jira)
2026/06/19
[PR] FLINK-39724: fix(python): support InternalTypeInfo in _from_java_type [flink]
via GitHub
2026/06/19
Re: [PR] [FLINK-39951][python] Fix string reference equality bug in ArrayConstructor causing silent long value truncation [flink]
via GitHub
2026/06/19
Re: [PR] [FLINK-39586][core] Mark the combined watermark status idle when all partial watermarks are unregistered [flink]
via GitHub
2026/06/19
Re: [PR] [FLINK-39586][core] Mark the combined watermark status idle when all partial watermarks are unregistered [flink]
via GitHub
2026/06/19
[jira] [Commented] (FLINK-39924) Memory fragmentation from jemalloc misconfiguration
Keith Lee (Jira)
2026/06/19
[jira] [Assigned] (FLINK-39959) Improve the autoscaler context structure and propagation
Gyula Fora (Jira)
2026/06/19
[jira] [Updated] (FLINK-39959) Improve the autoscaler context structure and propagation
Gyula Fora (Jira)
2026/06/19
[jira] [Closed] (FLINK-39555) FLIP-575: Scaling Executor Plugin SPI for Flink Autoscaler
Gyula Fora (Jira)
2026/06/19
Re: [PR] [FLINK-39555] FLIP-575: Scaling Executor Plugin SPI for Flink Autoscaler [flink-kubernetes-operator]
via GitHub
2026/06/19
Re: [PR] [FLINK-39555] FLIP-575: Scaling Executor Plugin SPI for Flink Autoscaler [flink-kubernetes-operator]
via GitHub
2026/06/19
Re: [PR] [FLINK-39555] FLIP-575: Scaling Executor Plugin SPI for Flink Autoscaler [flink-kubernetes-operator]
via GitHub
2026/06/19
[jira] [Created] (FLINK-39959) Improve the autoscaler context structure and propagation
Dennis-Mircea Ciupitu (Jira)
2026/06/19
Re: [PR] [FLINK-39923][state] Fix RocksDB Statistics native memory leak [flink]
via GitHub
2026/06/19
Re: [PR] [FLINK-39555] FLIP-575: Scaling Executor Plugin SPI for Flink Autoscaler [flink-kubernetes-operator]
via GitHub
2026/06/19
Re: [PR] [FLINK-39555] FLIP-575: Scaling Executor Plugin SPI for Flink Autoscaler [flink-kubernetes-operator]
via GitHub
2026/06/19
Re: [PR] [FLINK-39923][state] Fix RocksDB Statistics native memory leak [flink]
via GitHub
2026/06/19
Re: [PR] [FLINK-39923][state] Fix RocksDB Statistics native memory leak [flink]
via GitHub
2026/06/19
Re: [PR] [FLINK-39555] FLIP-575: Scaling Executor Plugin SPI for Flink Autoscaler [flink-kubernetes-operator]
via GitHub
2026/06/19
Re: [PR] [FLINK-39555] FLIP-575: Scaling Executor Plugin SPI for Flink Autoscaler [flink-kubernetes-operator]
via GitHub
2026/06/19
Re: [PR] [FLINK-39923][state] Fix RocksDB Statistics native memory leak [flink]
via GitHub
2026/06/19
Re: [PR] [hotfix] Replace deprecated procedure syntax for scala [flink]
via GitHub
2026/06/19
Re: [PR] [FLINK-39555] FLIP-575: Scaling Executor Plugin SPI for Flink Autoscaler [flink-kubernetes-operator]
via GitHub
2026/06/19
[jira] [Updated] (FLINK-39923) RocksDB Statistics native memory leaks on state backend rebuild when ticker metrics are enabled
ASF GitHub Bot (Jira)
2026/06/19
[PR] [FLINK-39923][state] Fix RocksDB Statistics native memory leak [flink]
via GitHub
2026/06/19
Re: [PR] [FLINK-32609] Support Projection Pushdown [flink-connector-kafka]
via GitHub
2026/06/19
Re: [PR] [FLINK-39555] FLIP-575: Scaling Executor Plugin SPI for Flink Autoscaler [flink-kubernetes-operator]
via GitHub
2026/06/19
Re: [PR] [FLINK-32609] Support Projection Pushdown [flink-connector-kafka]
via GitHub
2026/06/19
[jira] [Commented] (FLINK-38961) Display process metrics (CPU, Memory, I/O) on TaskManager Web UI
Purushottam Sinha (Jira)
2026/06/19
Re: [PR] [FLINK-38498]Fix JDBC Connector Data Type Mapping lacks: Mysql Timestamp and Postgres Timestamp_tz [flink-connector-jdbc]
via GitHub
2026/06/19
Re: [PR] [FLINK-39555] FLIP-575: Scaling Executor Plugin SPI for Flink Autoscaler [flink-kubernetes-operator]
via GitHub
2026/06/19
[jira] [Updated] (FLINK-33383) flink-quickstart-scala.sh is not supported anymore since 1.17 but is used in flink-web helper scripts
ASF GitHub Bot (Jira)
2026/06/19
[PR] [FLINK-33383] [Project Website] Remove deprecated Scala quickstart scripts [flink-web]
via GitHub
2026/06/19
Re: [PR] [FLINK-24544][formats] Fix Avro enum deserialization failure with Confluent Schema Registry [flink]
via GitHub
2026/06/19
[PR] [FLINK-24544][formats] Fix Avro enum deserialization failure with Confluent Schema Registry [flink]
via GitHub
2026/06/19
Re: [PR] [FLINK-37834] Flink JDBC support ClickHouse Dialect [flink-connector-jdbc]
via GitHub
2026/06/19
Re: [PR] [FLINK-39637][state] Add filter pushdown support for savepoint connector [flink]
via GitHub
2026/06/19
Re: [PR] [hotfix] Strip B/G scale subresource in process-classes so partial builds keep CRDs valid [flink-kubernetes-operator]
via GitHub
2026/06/19
Re: [PR] [hotfix] Strip B/G scale subresource in process-classes so partial builds keep CRDs valid [flink-kubernetes-operator]
via GitHub
2026/06/19
Re: [PR] [FLINK-34022][core] Fix ArithmeticException in TimeUtils.formatWithHighestUnit for large Duration values [flink]
via GitHub
2026/06/19
Re: [PR] [FLINK-39555] FLIP-575: Scaling Executor Plugin SPI for Flink Autoscaler [flink-kubernetes-operator]
via GitHub
2026/06/19
[jira] [Commented] (FLINK-39949) [ForSt] State restore from savepoints/checkpoints not supported
Martijn Visser (Jira)
2026/06/19
Re: [PR] [FLINK-33548] Replace taskManager/jobmanager.resource with resources conforming to ResourceRequirements [flink-kubernetes-operator]
via GitHub
2026/06/19
Re: [PR] [FLINK-33548] Replace taskManager/jobmanager.resource with resources conforming to ResourceRequirements [flink-kubernetes-operator]
via GitHub
2026/06/19
[PR] [hotfix] Strip B/G scale subresource in process-classes so partial builds keep CRDs valid [flink-kubernetes-operator]
via GitHub
2026/06/19
[jira] [Assigned] (FLINK-39730) ApplicationExceptionsHandler silently ignores maxExceptions parameter; ApplicationExceptionsMessageParameters is unreachable via typed REST client
Sergey Nuyanzin (Jira)
2026/06/19
[jira] [Resolved] (FLINK-39730) ApplicationExceptionsHandler silently ignores maxExceptions parameter; ApplicationExceptionsMessageParameters is unreachable via typed REST client
Sergey Nuyanzin (Jira)
2026/06/19
Re: [PR] [FLINK-39730][runtime] Honor maxExceptions on ApplicationExceptionsHandler [flink]
via GitHub
2026/06/19
[jira] [Commented] (FLINK-39730) ApplicationExceptionsHandler silently ignores maxExceptions parameter; ApplicationExceptionsMessageParameters is unreachable via typed REST client
Sergey Nuyanzin (Jira)
2026/06/19
Re: [PR] [hotfix][tests] Fix flaky `SessionRelatedITCase#testTouchSession` [flink]
via GitHub
2026/06/19
Re: [PR] [hotfix][table] Fix view comment derived from QueryOperation summary string [flink]
via GitHub
2026/06/19
Re: [PR] [FLINK-39499][tests] Replace MinIO with SeaweedFS [flink]
via GitHub
2026/06/19
Re: [PR] [hotfix] Replace deprecated procedure syntax for scala [flink]
via GitHub
2026/06/19
[PR] [hotfix][api] Remove unused Diffable markers from spec/status types [flink-kubernetes-operator]
via GitHub
2026/06/19
[jira] [Closed] (FLINK-39887) Use validated query node as a fallback when parsing the raw asQuery fails
Sergey Nuyanzin (Jira)
2026/06/19
[jira] [Commented] (FLINK-39887) Use validated query node as a fallback when parsing the raw asQuery fails
Sergey Nuyanzin (Jira)
2026/06/19
[PR] [hotfix] Replace deprecated procedure syntax for scala [flink]
via GitHub
2026/06/19
Re: [PR] [FLINK-33548] Replace taskManager/jobmanager.resource with resources conforming to ResourceRequirements [flink-kubernetes-operator]
via GitHub
2026/06/19
[jira] [Updated] (FLINK-39958) Autoscaler Flink REST client timeout is silently overridden by the operator client timeout
ASF GitHub Bot (Jira)
2026/06/19
[PR] [FLINK-39958] Autoscaler Flink REST client timeout is silently overridden by the operator client timeout [flink-kubernetes-operator]
via GitHub
2026/06/19
[jira] [Closed] (FLINK-30571) Compute scale parallelism based on observed scalability
Gyula Fora (Jira)
2026/06/19
[jira] [Closed] (FLINK-39441) Table configuration inside Flink config is not applying at runtime
Gyula Fora (Jira)
2026/06/19
[jira] [Closed] (FLINK-34728) operator does not need to upload and download the jar when deploying session job
Gyula Fora (Jira)
2026/06/19
[jira] [Closed] (FLINK-35285) Autoscaler key group optimization can interfere with scale-down.max-factor
Gyula Fora (Jira)
2026/06/19
[jira] [Closed] (FLINK-37682) Upgrade Jackson Lib to Address CVE-2023-35116
Gyula Fora (Jira)
2026/06/19
[jira] [Closed] (FLINK-38116) Flink kubernetes operator RequestWatchProgress Error
Gyula Fora (Jira)
2026/06/19
[jira] [Closed] (FLINK-38710) operator properties in FlinkDeployment are not taking effect
Gyula Fora (Jira)
2026/06/19
[jira] [Created] (FLINK-39958) Autoscaler Flink REST client timeout is silently overridden by the operator client timeout
Dennis-Mircea Ciupitu (Jira)
2026/06/19
Re: [PR] [hotfix][table] Fix view comment derived from QueryOperation summary string [flink]
via GitHub
2026/06/19
Re: [PR] [hotfix][table] Fix view comment derived from QueryOperation summary string [flink]
via GitHub
2026/06/19
Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink]
via GitHub
2026/06/19
Re: [PR] Bump flatted from 3.3.2 to 3.4.2 in /flink-runtime-web/web-dashboard [flink]
via GitHub
2026/06/19
Re: [PR] [hotfix][docs] Clarify Kryo behavior [flink]
via GitHub
2026/06/19
Re: [PR] [hotfix][docs] Clarify Kryo behavior [flink]
via GitHub
2026/06/19
Re: [PR] Add AWS Connectors 6.0.1 [flink-web]
via GitHub
2026/06/19
[jira] [Comment Edited] (FLINK-39725) from_source does not use timestamp assigner in pyflink
Swati Gupta (Jira)
2026/06/19
Re: [PR] [FLINK-39586][core] Mark the combined watermark status idle when all partial watermarks are unregistered [flink]
via GitHub
2026/06/19
[jira] [Created] (FLINK-39957) Support EXPLAIN CREATE [OR ALTER] MATERIALIZED TABLE statements
Ramin Gharib (Jira)
2026/06/19
[jira] [Updated] (FLINK-39586) CombinedWatermarkStatus.updateCombinedWatermark() fails to mark idle when partialWatermarks is empty
ASF GitHub Bot (Jira)
2026/06/19
[PR] FLINK-39586: Mark the combined watermark status idle when all partial watermarks are unregistered [flink]
via GitHub
2026/06/19
[jira] [Commented] (FLINK-39725) from_source does not use timestamp assigner in pyflink
Swati Gupta (Jira)
2026/06/18
Re: [PR] [hotfix][tests] Fix flaky `SessionRelatedITCase#testTouchSession` [flink]
via GitHub
2026/06/18
Re: [PR] [hotfix] warning for conditional [flink]
via GitHub
2026/06/18
[PR] [hotfix][tests] Fix flaky `SessionRelatedITCase#testTouchSession` [flink]
via GitHub
2026/06/18
[jira] [Commented] (FLINK-39956) Expose per-pool heap CollectionUsage gauges
Swati Gupta (Jira)
2026/06/18
Re: [PR] [FLINK-34415] Move away from Kafka-Zookeeper based tests in favor of Kafka-KRaft [flink]
via GitHub
2026/06/18
Re: [PR] [FLINK-39898][runtime] Fire processing-time timers between unaligned checkpoints when mini-batch is enabled [flink]
via GitHub
2026/06/18
[PR] [FLINK-39898][runtime] Fire processing-time timers between unaligned checkpoints when mini-batch is enabled [flink]
via GitHub
2026/06/18
Re: [PR] FLINK-39898: Fire processing-time timers between unaligned checkpoints when mini-batch is enabled [flink]
via GitHub
2026/06/18
Re: [PR] FLINK-39898: Fire processing-time timers between unaligned checkpoints when mini-batch is enabled [flink]
via GitHub
2026/06/18
[jira] [Comment Edited] (FLINK-39949) [ForSt] State restore from savepoints/checkpoints not supported
Jubin Soni (Jira)
2026/06/18
[jira] [Comment Edited] (FLINK-39949) [ForSt] State restore from savepoints/checkpoints not supported
Jubin Soni (Jira)
2026/06/18
[jira] [Updated] (FLINK-39898) ProcessingTimeService timer callbacks delayed until checkpoint when mini-batch and unaligned checkpoints are enabled
ASF GitHub Bot (Jira)
2026/06/18
[PR] FLINK-39898: Fire processing-time timers between unaligned checkpoints when mini-batch is enabled [flink]
via GitHub
2026/06/18
[jira] [Commented] (FLINK-39949) [ForSt] State restore from savepoints/checkpoints not supported
Jubin Soni (Jira)
2026/06/18
[jira] [Commented] (FLINK-39949) [ForSt] State restore from savepoints/checkpoints not supported
Jubin Soni (Jira)
2026/06/18
Re: [PR] [FLINK-39873][streaming] Add null check for `connectedSocket` in `SocketStreamIterator.notifyOfError()` [flink]
via GitHub
2026/06/18
Re: [PR] [FLINK-39837][connectors] Add tombstone-based retention for removed splits in dynamic sources [flink]
via GitHub
2026/06/18
Re: [PR] [FLINK-38449][core] Reject fractional MemorySize values with explicit error [flink]
via GitHub
2026/06/18
Re: [PR] [FLINK-39572] [python] Hide sensitive process environment values in logs [flink]
via GitHub
2026/06/18
[jira] [Updated] (FLINK-39193) SpecifiedOffsetsInitializer can fail if the caller passes a non-empty but incomplete specific-offset map.
Bowen Li (Jira)
2026/06/18
[jira] [Closed] (FLINK-39054) DynamicKafkaSourceEnumStateSerializer should preserve full per-cluster properties instead of only bootstrap.servers
Bowen Li (Jira)
2026/06/18
[jira] [Updated] (FLINK-39054) DynamicKafkaSourceEnumStateSerializer should preserve full per-cluster properties instead of only bootstrap.servers
Bowen Li (Jira)
2026/06/18
[jira] [Created] (FLINK-39956) Expose per-pool heap CollectionUsage gauges
Zhenqiu Huang (Jira)
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
Re: [PR] [FLINK-37834] Flink JDBC support ClickHouse Dialect [flink-connector-jdbc]
via GitHub
2026/06/18
Re: [PR] [FLINK-39499][tests] Replace MinIO with SeaweedFS [flink]
via GitHub
Earlier messages
Later messages