issues  

Messages by Date

• 2026/06/03 Re: [PR] Rewrite security page with precise trust model and operator coverage [flink-web] via GitHub
• 2026/06/03 [PR] [hotfix] Correct fabric8 version to 7.3.1 in NOTICE files [flink-kubernetes-operator] via GitHub
• 2026/06/03 Re: [PR] [FLINK-39713] Bump log4j, jackson, and Beam to retire CVEs [flink-kubernetes-operator] via GitHub
• 2026/06/03 Re: [PR] [hotfix] Bump `flink-connector-parent` to 1.1.0 [flink-connector-aws] via GitHub
• 2026/06/03 [jira] [Closed] (FLINK-27941) [JUnit5 Migration] Module: flink-connector-kinesis Ferenc Csaky (Jira)
• 2026/06/03 Re: [PR] [FLINK-27941][connectors/aws] Migrate remaining tests to JUnit 5 [flink-connector-aws] via GitHub
• 2026/06/03 Re: [PR] [FLINK-27941][connectors/aws] Migrate remaining tests to JUnit 5 [flink-connector-aws] via GitHub
• 2026/06/03 [jira] [Assigned] (FLINK-27941) [JUnit5 Migration] Module: flink-connector-kinesis Ferenc Csaky (Jira)
• 2026/06/03 [jira] [Updated] (FLINK-27941) [JUnit5 Migration] Module: flink-connector-kinesis Ferenc Csaky (Jira)
• 2026/06/03 [jira] [Updated] (FLINK-27941) [JUnit5 Migration] Module: flink-connector-kinesis Ferenc Csaky (Jira)
• 2026/06/03 [jira] [Closed] (FLINK-20979) Wrong description of 'sink.bulk-flush.max-actions' Ferenc Csaky (Jira)
• 2026/06/03 [jira] [Updated] (FLINK-20979) Wrong description of 'sink.bulk-flush.max-actions' Ferenc Csaky (Jira)
• 2026/06/03 [jira] [Updated] (FLINK-20979) Wrong description of 'sink.bulk-flush.max-actions' Ferenc Csaky (Jira)
• 2026/06/03 Re: [PR] [FLINK-20979][elasticsearch] Fix docs: use '-1' to disable bulk-flush options [flink-connector-elasticsearch] via GitHub
• 2026/06/03 [jira] [Updated] (FLINK-20979) Wrong description of 'sink.bulk-flush.max-actions' Ferenc Csaky (Jira)
• 2026/06/03 [jira] [Updated] (FLINK-20979) Wrong description of 'sink.bulk-flush.max-actions' Ferenc Csaky (Jira)
• 2026/06/03 Re: [PR] [FLINK-36602][table] Upgrade Calcite version to 1.38.0 [flink] via GitHub
• 2026/06/03 Re: [PR] [FLINK-39817][table] Upgrade Calcite version to 1.39.0 [flink] via GitHub
• 2026/06/03 Re: [PR] Bump org.postgresql:postgresql from 42.5.6 to 42.7.11 in /flink-autoscaler-plugin-jdbc [flink-kubernetes-operator] via GitHub
• 2026/06/03 Re: [PR] Bump org.postgresql:postgresql from 42.5.6 to 42.7.11 in /flink-autoscaler-plugin-jdbc [flink-kubernetes-operator] via GitHub
• 2026/06/03 Re: [PR] Bump org.postgresql:postgresql from 42.5.6 to 42.7.11 in /flink-autoscaler-plugin-jdbc [flink-kubernetes-operator] via GitHub
• 2026/06/03 Re: [PR] [FLINK-39136][BP 2.3][filesystems] Bump google-cloud-storage to 2.68.0 in flink-gs-fs-hadoop [flink] via GitHub
• 2026/06/03 Re: [PR] [FLINK-39835][runtime] AsyncWaitOperator supports soft backpressure to avoid blocking unaligned checkpoint [flink] via GitHub
• 2026/06/03 Re: [PR] [FLINK-39777] Support configurable HashFunction strategies in PrePartitionOperator [flink-cdc] via GitHub
• 2026/06/03 [jira] [Updated] (FLINK-39680) Enable unaligned checkpoint for pointwise connection by FORCE_UNALIGNED Gen Luo (Jira)
• 2026/06/03 [jira] [Updated] (FLINK-39835) AsyncWaitOperator supports soft backpressure to avoid blocking unaligned checkpoint ASF GitHub Bot (Jira)
• 2026/06/03 [PR] [FLINK-39835][runtime] AsyncWaitOperator supports soft backpressure to avoid blocking unaligned checkpoint [flink] via GitHub
• 2026/06/03 Re: [PR] [FLINK-39680][runtime] AsyncWaitOperator supports soft backpressure to avoid blocking unaligned checkpoint [flink] via GitHub
• 2026/06/03 [jira] [Updated] (FLINK-39680) Enable unaligned checkpoint for pointwise connection by FORCE_UNALIGNED ASF GitHub Bot (Jira)
• 2026/06/03 [PR] [FLINK-39680][runtime] AsyncWaitOperator supports soft backpressure to avoid blocking unaligned checkpoint [flink] via GitHub
• 2026/06/03 Re: [PR] [FLINK-39583][table-planner] Normalize Calcite correl variables for more effective sub-plan digest reuse [flink] via GitHub
• 2026/06/03 Re: [PR] [FLINK-39691] Fix toString for AggregatedMetric [flink-kubernetes-operator] via GitHub
• 2026/06/03 Re: [PR] [FLINK-39692][Kubernetes-Operator] Include caught exceptions in warn/error log statements [flink-kubernetes-operator] via GitHub
• 2026/06/03 [jira] [Created] (FLINK-39835) AsyncWaitOperator supports soft backpressure to avoid blocking unaligned checkpoint Gen Luo (Jira)
• 2026/06/03 [PR] [hotfix] Use explicit UTF-8 charset in coerceToBytes and guard Optional.get() in Kafka serializers [flink-cdc] via GitHub
• 2026/06/03 Re: [PR] Add Pulsar Connector 4.2.0 [flink-web] via GitHub
• 2026/06/03 [jira] [Updated] (FLINK-39697) Bump Flink version to 2.2.1 Ferenc Csaky (Jira)
• 2026/06/03 Re: [PR] [docs] Update the FAQ section for release 0.3 [flink-agents] via GitHub
• 2026/06/03 Re: [PR] Add Flink 1.20.5 release [flink-web] via GitHub
• 2026/06/03 [PR] [docs] Update the FAQ section for release 0.3 [flink-agents] via GitHub
• 2026/06/03 [PR] [FLINK-39834] Fix Oracle UNISTR parsing with embedded concat operator [flink-cdc] via GitHub
• 2026/06/03 [jira] [Created] (FLINK-39834) Oracle CDC may duplicate UNISTR expressions when UNISTR value contains || tianfy (Jira)
• 2026/06/03 Re: [PR] Add Flink 1.20.5 release [flink-web] via GitHub
• 2026/06/03 Re: [PR] [FLINK-39767][tests][JUnit5 migration] Module: flink-statebackend-forst [flink] via GitHub
• 2026/06/03 Re: [PR] [FLINK-39767][tests][JUnit5 migration] Module: flink-statebackend-forst [flink] via GitHub
• 2026/06/03 Re: [PR] [FLINK-39767][tests][JUnit5 migration] Module: flink-statebackend-forst [flink] via GitHub
• 2026/06/03 [jira] [Resolved] (FLINK-39829) Bump scala to 2.12.21 Sergey Nuyanzin (Jira)
• 2026/06/03 [jira] [Commented] (FLINK-39829) Bump scala to 2.12.21 Sergey Nuyanzin (Jira)
• 2026/06/03 Re: [PR] [FLINK-39829][build] Bump scala to 2.12.21 [flink] via GitHub
• 2026/06/03 Re: [PR] [FLINK-39822][tests] Wait for partition assignment in test createTopics calls [flink-connector-kafka] via GitHub
• 2026/06/03 Re: [PR] [FLINK-39829][build] Bump scala to 2.12.21 [flink] via GitHub
• 2026/06/03 Re: [PR] [FLINK-39821][table] Make REGEXP_REPLACE return type nullable [flink] via GitHub
• 2026/06/03 Re: [PR] [FLINK-39825] Add support for State TTL and eviction in ProcessTableFunctionTestHarness [flink] via GitHub
• 2026/06/03 Re: [PR] [FLINK-39825] Add support for State TTL and eviction in ProcessTableFunctionTestHarness [flink] via GitHub
• 2026/06/03 Re: [PR] [FLINK-39637][state] Add filter pushdown support for savepoint connector [flink] via GitHub
• 2026/06/03 Re: [I] [Bug] AgentPlan resource getter is not thread-safe on release-0.2 [flink-agents] via GitHub
• 2026/06/03 Re: [I] [Bug] AgentPlan resource getter is not thread-safe on release-0.2 [flink-agents] via GitHub
• 2026/06/03 Re: [PR] [python][plan] Make AgentPlan.getResource thread-safe (backport #548 to release-0.2) [flink-agents] via GitHub
• 2026/06/03 Re: [PR] [FLINK-39136][BP 2.0][filesystems] Bump google-cloud-storage to 2.68.0 in flink-gs-fs-hadoop [flink] via GitHub
• 2026/06/03 Re: [PR] [FLINK-39637][state] Add filter pushdown support for savepoint connector [flink] via GitHub
• 2026/06/03 Re: [PR] [FLINK-39376][runtime-web] Add TaskManager endpoint to checkpoint subtask statistics [flink] via GitHub
• 2026/06/03 Re: [PR] [FLINK-39825] Add support for State TTL and eviction in ProcessTableFunctionTestHarness [flink] via GitHub
• 2026/06/03 [PR] [FLINK-39136][BP 2.0][filesystems] Bump google-cloud-storage to 2.68.0 in flink-gs-fs-hadoop [flink] via GitHub
• 2026/06/03 Re: [PR] [FLINK-39383][Docs] Improve scan.incremental.snapshot.chunk.key-column documentation for MySQL/PostgreSQL/Oracle/DB2/SQLServer connectors [flink-cdc] via GitHub
• 2026/06/03 Re: [PR] [FLINK-39825] Add support for State TTL and eviction in ProcessTableFunctionTestHarness [flink] via GitHub
• 2026/06/03 Re: [PR] Add Flink 2.3.0 release [flink-web] via GitHub
• 2026/06/03 [PR] [FLINK-39833][pipeline][starrocks] Escape special characters in column comment and default value when building DDL [flink-cdc] via GitHub
• 2026/06/03 [jira] [Updated] (FLINK-38498) JDBC Connector Data Type Mapping lacks: Mysql Timestamp and Postgres Timestamp_tz ASF GitHub Bot (Jira)
• 2026/06/03 [jira] [Updated] (FLINK-39833) Special characters in column comment and default value are not escaped when building DDL ASF GitHub Bot (Jira)
• 2026/06/03 [PR] [FLINK-38498]Fix JDBC Connector Data Type Mapping lacks: Mysql Timestamp and Postgres Timestamp_tz [flink-connector-jdbc] via GitHub
• 2026/06/03 Re: [PR] [FLINK-38498]Fix JDBC Connector Data Type Mapping lacks: Mysql Timestamp and Postgres Timestamp_tz [flink-connector-jdbc] via GitHub
• 2026/06/03 [jira] [Created] (FLINK-39833) Special characters in column comment and default value are not escaped when building DDL SkylerLin (Jira)
• 2026/06/03 Re: [PR] [FLINK-39136][BP 2.1][filesystems] Bump google-cloud-storage to 2.68.0 in flink-gs-fs-hadoop [flink] via GitHub
• 2026/06/03 Re: [PR] [FLINK-39136][BP 2.2][filesystems] Bump google-cloud-storage to 2.68.0 in flink-gs-fs-hadoop [flink] via GitHub
• 2026/06/03 [PR] [FLINK-39136][BP 2.1][filesystems] Bump google-cloud-storage to 2.68.0 in flink-gs-fs-hadoop [flink] via GitHub
• 2026/06/03 Re: [PR] Bump immutable from 5.1.3 to 5.1.5 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/06/03 Re: [PR] [FLINK-38946][flink-metrics] Allow AWS PrivateLink/GCP Cloud Private Service Connect for Datadog integration [flink] via GitHub
• 2026/06/03 Re: [PR] [hotfix] Intermittent unit test failures we have hit in ExecutionGraph tests [flink] via GitHub
• 2026/06/03 Re: [PR] [FLINK-38946][flink-metrics] Allow AWS PrivateLink/GCP Cloud Private Service Connect for Datadog integration [flink] via GitHub
• 2026/06/03 Re: [PR] [hotfix] Intermittent unit test failures we have hit in ExecutionGraph tests [flink] via GitHub
• 2026/06/03 Re: [PR] [hotfix] Rename registeredSlots to allocatedSlots [flink] via GitHub
• 2026/06/03 [PR] [FLINK-39136][BP 2.2][filesystems] Bump google-cloud-storage to 2.68.0 in flink-gs-fs-hadoop [flink] via GitHub
• 2026/06/03 Re: [PR] [hotfix] Unify the name for the collection of SlotOffer with slotOffers [flink] via GitHub
• 2026/06/03 Re: [PR] [hotfix] Unify the name for the collection of SlotOffer with slotOffers [flink] via GitHub
• 2026/06/03 Re: [PR] [hotfix] Rename registeredSlots to allocatedSlots [flink] via GitHub
• 2026/06/03 Re: [PR] [hotfix] Simplify the calling on addShutdownHook [flink] via GitHub
• 2026/06/03 Re: [PR] [hotfix] Simplify the calling on addShutdownHook [flink] via GitHub
• 2026/06/03 [I] [Bug] Name of metrics dynamically change [flink-agents] via GitHub
• 2026/06/03 Re: [PR] [FLINK-39136][BP 2.3][filesystems] Bump google-cloud-storage to 2.68.0 in flink-gs-fs-hadoop [flink] via GitHub
• 2026/06/03 [PR] [FLINK-39136][BP 2.3][filesystems] Bump google-cloud-storage to 2.68.0 in flink-gs-fs-hadoop [flink] via GitHub
• 2026/06/03 [I] [Release] Manual verification integrate with flink section of user documentation [flink-agents] via GitHub
• 2026/06/03 [I] [Release] Manual verification yaml section of user documentation [flink-agents] via GitHub
• 2026/06/03 [I] [Release] Manual verification react section of user documentation [flink-agents] via GitHub
• 2026/06/03 [I] [Release] Manual verification vector stores section of user documentation [flink-agents] via GitHub
• 2026/06/03 [I] [Release] Manual verification prompt section of user documentation [flink-agents] via GitHub
• 2026/06/03 [I] [Release] Manual verification FAQ section of user documentation [flink-agents] via GitHub
• 2026/06/03 [I] [Release] Manual verification embedding model section of user documentation [flink-agents] via GitHub
• 2026/06/03 [I] [Release] Manual verification chat model section of user documentation [flink-agents] via GitHub
• 2026/06/03 [I] [Release] Manual verification monitoring section of user documentation [flink-agents] via GitHub
• 2026/06/03 [I] [Release] Manual verification configuration section of user documentation [flink-agents] via GitHub
• 2026/06/03 Re: [PR] [FLINK-33548] Replace taskManager/jobmanager.resource with resources conforming to ResourceRequirements [flink-kubernetes-operator] via GitHub
• 2026/06/03 [I] [Release] Manual verification deployment section of user documentation [flink-agents] via GitHub
• 2026/06/03 Re: [PR] [FLINK-33548] Replace taskManager/jobmanager.resource with resources conforming to ResourceRequirements [flink-kubernetes-operator] via GitHub
• 2026/06/02 Re: [PR] [FLINK-39136][filesystems] Bump google-cloud-storage to 2.68.0 in flink-gs-fs-hadoop [flink] via GitHub
• 2026/06/02 [jira] [Assigned] (FLINK-39445) [release-2.3] Select executing release manager Yuepeng Pan (Jira)
• 2026/06/02 [jira] [Updated] (FLINK-39136) GS file system fails to retry on certain 503's due to old GCS lib dependency Yuepeng Pan (Jira)
• 2026/06/02 [jira] [Updated] (FLINK-39820) Update delta join documentation with new features in 2.3 Yuepeng Pan (Jira)
• 2026/06/02 [PR] [FLINK-39832] Fix Oracle NUMBER(p,0) with p>=19 incorrectly mapped to BIGINT [flink-cdc] via GitHub
• 2026/06/02 [jira] [Updated] (FLINK-39832) [Bug] Oracle pipeline connector maps NUMBER(p,0) with p>=19 to BIGINT, causing primary key collision and row collapse in downstream sinks ASF GitHub Bot (Jira)
• 2026/06/02 [jira] [Updated] (FLINK-39832) [Bug] Oracle pipeline connector maps NUMBER(p,0) with p>=19 to BIGINT, causing primary key collision and row collapse in downstream sinks Zhouqing (Jira)
• 2026/06/02 Re: [PR] [FLINK-39777] Support configurable HashFunction strategies in PrePartitionOperator [flink-cdc] via GitHub
• 2026/06/02 Re: [PR] [FLINK-39777] Support configurable HashFunction strategies in PrePartitionOperator [flink-cdc] via GitHub
• 2026/06/02 [jira] [Resolved] (FLINK-39811) S5cmd effective concurrency capped by static part size for small downloads Piotr Nowojski (Jira)
• 2026/06/02 [jira] [Updated] (FLINK-39811) S5cmd effective concurrency capped by static part size for small downloads Piotr Nowojski (Jira)
• 2026/06/02 [jira] [Created] (FLINK-39832) [Bug] Oracle pipeline connector maps NUMBER(p,0) with p>=19 to BIGINT, causing primary key collision and row collapse in downstream sinks Zhouqing (Jira)
• 2026/06/02 Re: [PR] [FLINK-39811][s3] Optionally Adjust s5cmd part size to fully utilize s5cmd workers pool during downloads [flink] via GitHub
• 2026/06/02 [jira] [Updated] (FLINK-39811) S5cmd effective concurrency capped by static part size for small downloads Efrat Levitan (Jira)
• 2026/06/02 [jira] [Updated] (FLINK-39811) S5cmd effective concurrency capped by static part size for small downloads Efrat Levitan (Jira)
• 2026/06/02 [jira] [Updated] (FLINK-39811) S5cmd effective concurrency capped by static part size for small downloads Efrat Levitan (Jira)
• 2026/06/02 [jira] [Commented] (FLINK-39811) S5cmd effective concurrency capped by static part size for small downloads Piotr Nowojski (Jira)
• 2026/06/02 [jira] [Updated] (FLINK-39811) S5cmd effective concurrency capped by static part size for small downloads Piotr Nowojski (Jira)
• 2026/06/02 Re: [PR] [FLINK-39811][s3] Optionally Adjust s5cmd part size to fully utilize s5cmd workers pool during downloads [flink] via GitHub
• 2026/06/02 [jira] [Updated] (FLINK-39811) S5cmd effective concurrency capped by static part size for small downloads Piotr Nowojski (Jira)
• 2026/06/02 [jira] [Updated] (FLINK-39811) S5cmd effective concurrency capped by static part size for small downloads Piotr Nowojski (Jira)
• 2026/06/02 Re: [PR] [FLINK-39811][s3] Optionally Adjust s5cmd part size to fully utilize s5cmd workers pool during downloads [flink] via GitHub
• 2026/06/02 [jira] [Created] (FLINK-39831) Integrate MetricsAware Interface with Native-s3-fs Samrat Deb (Jira)
• 2026/06/02 [jira] [Created] (FLINK-39830) Introduce MetricsAware Interface Samrat Deb (Jira)
• 2026/06/02 Re: [PR] [FLINK-39829][build] Bump scala to 2.12.21 [flink] via GitHub
• 2026/06/02 [jira] [Updated] (FLINK-39829) Bump scala to 2.12.21 ASF GitHub Bot (Jira)
• 2026/06/02 [PR] [FLINK-39829][build] Bump scala to 2.12.21 [flink] via GitHub
• 2026/06/02 [jira] [Created] (FLINK-39829) Bump scala to 2.12.21 Sergey Nuyanzin (Jira)
• 2026/06/02 Re: [PR] [hotfix][docs] Update Kafka connector doc version [flink] via GitHub
• 2026/06/02 Re: [D] [Discussion] Trigger action by Event Field Values [flink-agents] via GitHub
• 2026/06/02 [I] [Tech Debt] Check commits' corresponding issues / PRs are properly labeled and documentations are completed [flink-agents] via GitHub
• 2026/06/02 [I] [Release] Check issues and PRs are correctly labeled [flink-agents] via GitHub
• 2026/06/02 Re: [I] [Bug] OpenSearchVectorStore fails against Amazon OpenSearch Serverless (AOSS) [flink-agents] via GitHub
• 2026/06/02 [I] [Release] Prepare release announcement for Flink Agents 0.3.0 [flink-agents] via GitHub
• 2026/06/02 Re: [PR] [FLINK-39777] Support configurable HashFunction strategies in PrePartitionOperator [flink-cdc] via GitHub
• 2026/06/02 [I] [Tech Debt] Manual verification following the user documentation [flink-agents] via GitHub
• 2026/06/02 [I] [Umbrella] Flink Agents 0.3.0 release verification [flink-agents] via GitHub
• 2026/06/02 Re: [PR] [FLINK-39792] Add multi-headers metadata key to Kafka connector [flink-connector-kafka] via GitHub
• 2026/06/02 Re: [PR] [FLINK-39792] Add multi-headers metadata key to Kafka connector [flink-connector-kafka] via GitHub
• 2026/06/02 [jira] [Updated] (FLINK-39777) Support configurable HashFunction strategies in PrePartitionOperator ASF GitHub Bot (Jira)
• 2026/06/02 [PR] [FLINK-39777] Support configurable HashFunction strategies in PrePartitionOperator [flink-cdc] via GitHub
• 2026/06/02 Re: [PR] [FLINK-39758] Fix DECIMAL OOB in SchemaMergingUtils [flink-cdc] via GitHub
• 2026/06/02 [jira] [Resolved] (FLINK-39621) Incremental-snapshot based sources may get stuck in binlog-backfill stage Yanquan Lv (Jira)
• 2026/06/02 [jira] [Resolved] (FLINK-39582) [cdc-connector][postgres] Support emitting pg_logical_emit_message records to deserialization Yanquan Lv (Jira)
• 2026/06/02 [jira] [Assigned] (FLINK-39582) [cdc-connector][postgres] Support emitting pg_logical_emit_message records to deserialization Yanquan Lv (Jira)
• 2026/06/02 [jira] [Resolved] (FLINK-38450) flink-cdc sink to iceberg table record duplication Yanquan Lv (Jira)
• 2026/06/02 Re: [PR] [FLINK-38450][iceberg] Fix duplicate records when schema change splits writes within a checkpoint [flink-cdc] via GitHub
• 2026/06/02 Re: [PR] [FLINK-38450][iceberg] Fix duplicate records when schema change splits writes within a checkpoint [flink-cdc] via GitHub
• 2026/06/02 Re: [PR] [FLINK-39758] Fix DECIMAL OOB in SchemaMergingUtils [flink-cdc] via GitHub
• 2026/06/02 [PR] Add Flink 1.20.4 release [flink-web] via GitHub
• 2026/06/02 Re: [PR] [FLINK-38242] Improve upgrading documentation for SQL/Table API state compatibility and add Flink 2.x to compatibility table [flink] via GitHub
• 2026/06/02 Re: [PR] [FLINK-38477][runtime] Add FINISHED watermark status to support proper watermark aggregation [flink] via GitHub
• 2026/06/02 Re: [PR] Add Flink 2.3.0 release [flink-web] via GitHub
• 2026/06/02 [jira] [Resolved] (FLINK-35761) FLIP-547: Support checkpoint during recovery Rui Fan (Jira)
• 2026/06/02 Re: [PR] [FLINK-39828][table] Upgrade Calcite to 1.40.0 [flink] via GitHub
• 2026/06/02 [jira] [Updated] (FLINK-39828) Upgrade Calcite version to 1.40.0 ASF GitHub Bot (Jira)
• 2026/06/02 [PR] [FLINK-39828][table] Upgrade Calcite to 1.40.0 [flink] via GitHub
• 2026/06/02 Re: [I] [Bug] Python memory can persist Pemja-incompatible values and fail after state backend restore [flink-agents] via GitHub
• 2026/06/02 [jira] [Created] (FLINK-39828) Upgrade Calcite version to 1.40.0 Sergey Nuyanzin (Jira)
• 2026/06/02 Re: [PR] [FLINK-39637][state] Add filter pushdown support for savepoint connector [flink] via GitHub
• 2026/06/02 [PR] [python][plan] Make AgentPlan.getResource thread-safe (backport #548 to release-0.2) [flink-agents] via GitHub
• 2026/06/02 Re: [I] [Bug] AgentPlan resource getter is not thread-safe on release-0.2 [flink-agents] via GitHub
• 2026/06/02 Re: [PR] [hotfix][docs] Update Kafka connector doc version [flink] via GitHub
• 2026/06/02 [PR] [hotfix][docs] Update Kafka connector doc version [flink] via GitHub
• 2026/06/02 Re: [PR] Add Kafka Connector 5.0.0 [flink-web] via GitHub
• 2026/06/02 Re: [PR] [feature][integration][java] Add built-in Google Gemini chat model integration [flink-agents] via GitHub
• 2026/06/02 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/02 [jira] [Updated] (FLINK-39761) Missing 'Connection: close' header on '304 Not Modified' responses causes proxy connection pool poisoning Ferenc Csaky (Jira)
• 2026/06/02 Re: [PR] [FLINK-39761][runtime] Set 'Connection: close' header when sending '304 Not Modified' responses [flink] via GitHub
• 2026/06/02 [jira] [Assigned] (FLINK-39802) Fix flaky ProfilingServiceTest.testRollingDeletion by isolating the test and applying Interface Segregation to ProfilingService Ferenc Csaky (Jira)
• 2026/06/02 Re: [PR] Add Flink 2.3.0 release [flink-web] via GitHub
• 2026/06/02 Re: [PR] Add Flink 2.3.0 release [flink-web] via GitHub
• 2026/06/02 Re: [PR] [FLINK-39808] Tighten FlinkVersion.isSupported() to reject @Deprecated versions and restore the deprecate-and-raise-floor pattern [flink-kubernetes-operator] via GitHub
• 2026/06/02 [jira] [Commented] (FLINK-39786) closeForCommit() leaks orphan multipart uploads on upload failure Samrat Deb (Jira)
• 2026/06/02 Re: [PR] [FLINK-39819] Avoid redundant JSON String round-trips in SpecUtils.clone and DiffResult.toString [flink-kubernetes-operator] via GitHub
• 2026/06/02 [jira] [Assigned] (FLINK-39827) [umbrella] Adopt JobInfo on source contexts Rui Fan (Jira)
• 2026/06/02 [jira] [Updated] (FLINK-39826) Strengthen autoscaler configuration validation ASF GitHub Bot (Jira)
• 2026/06/02 [PR] [FLINK-39826][autoscaler] Strengthen autoscaler configuration validation [flink-kubernetes-operator] via GitHub
• 2026/06/02 Re: [PR] [FLINK-27941][connectors/aws] Migrate remaining tests to JUnit 5 [flink-connector-aws] via GitHub
• 2026/06/02 [jira] [Created] (FLINK-39827) [umbrella] Adopt JobInfo on source contexts Aleksandr Savonin (Jira)
• 2026/06/02 [jira] [Created] (FLINK-39826) Strengthen autoscaler configuration validation Dennis-Mircea Ciupitu (Jira)
• 2026/06/02 [PR] [FLINK-39822][tests] Wait for partition assignment in KafkaSinkExternalContext.createTopic [flink-connector-kafka] via GitHub
• 2026/06/02 [jira] [Updated] (FLINK-39822) All createTopics calls in tests should wait for partition assignment ASF GitHub Bot (Jira)
• 2026/06/02 [jira] [Commented] (FLINK-39723) KafkaTableITCase.testExactlyOnceSink fails due to transactional ID reuse across test runs Aleksandr Savonin (Jira)
• 2026/06/02 [jira] [Assigned] (FLINK-39822) All createTopics calls in tests should wait for partition assignment Roman Khachatryan (Jira)
• 2026/06/02 Re: [PR] [FLINK-38469][python] Bump Apache Beam to 2.72 [flink] via GitHub
• 2026/06/02 [jira] [Resolved] (FLINK-39651) REGEXP predicate does not validate literal regex patterns at plan time and logs errors on the hot path Fabian Hueske (Jira)
• 2026/06/02 Re: [PR] [FLINK-39258][table] Extend restore tests for TO_CHANGELOG and FROM_CHANGELOG [flink] via GitHub
• 2026/06/02 Re: [PR] [FLINK-39651][table] REGEXP plan-time validation and hot-path log cleanup [flink] via GitHub
• 2026/06/02 Re: [PR] [FLINK-39819] Avoid redundant JSON String round-trips in SpecUtils.clone and DiffResult.toString [flink-kubernetes-operator] via GitHub
• 2026/06/02 Re: [PR] [hotfix] Clean up FlinkBlueGreenDeploymentController [flink-kubernetes-operator] via GitHub
• 2026/06/02 Re: [PR] [hotfix] Reuse FlinkConfigManager#isSnapshotCrdInstalled in controllers [flink-kubernetes-operator] via GitHub
• 2026/06/02 [jira] [Commented] (FLINK-39808) Tighten FlinkVersion.isSupported() to reject @Deprecated versions and restore the deprecate-and-raise-floor pattern Gyula Fora (Jira)
• 2026/06/02 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/02 Re: [PR] [FLINK-39825] Add support for State TTL and eviction in ProcessTableFunctionTestHarness [flink] via GitHub
• 2026/06/02 Re: [PR] [FLINK-39790][state/metrics] Fix State latency/size tracking metrics not exported without sampling [flink] via GitHub
• 2026/06/02 [jira] [Updated] (FLINK-39825) Add support for state TTL in ProcessTableFunctionTestHarness ASF GitHub Bot (Jira)

• Earlier messages
• Later messages