issues  

Messages by Date

• 2026/06/22 [jira] [Updated] (FLINK-38851) Support passing arbitrary database options to JDBC Catalog Yuepeng Pan (Jira)
• 2026/06/22 [jira] [Created] (FLINK-39973) Release flink-connector-jdbc v4.0.0 for Flink 2.0 Chanhae Oh (Jira)
• 2026/06/22 [jira] [Updated] (FLINK-33463) Support the implementation of dynamic source tables based on the new source Yuepeng Pan (Jira)
• 2026/06/22 [jira] [Updated] (FLINK-38732) Enable the stale bot for the JDBC connector Yuepeng Pan (Jira)
• 2026/06/22 [PR] [FLINK-37448] Report actual TaskManager count in status.taskManager.replicas [flink-kubernetes-operator] via GitHub
• 2026/06/22 [jira] [Updated] (FLINK-36236) JdbcSourceBuilder overrides set connection provider Yuepeng Pan (Jira)
• 2026/06/22 [jira] [Updated] (FLINK-34467) Implement Lineage Interface in Jdbc Connector Yuepeng Pan (Jira)
• 2026/06/22 [jira] [Updated] (FLINK-39972) Release flink-connector-jdbc v3.4.0 for Flink 1.20 Chanhae Oh (Jira)
• 2026/06/22 [jira] [Updated] (FLINK-36303) PostgreSQL timestamp precision 0 not supported Yuepeng Pan (Jira)
• 2026/06/22 [jira] [Updated] (FLINK-36659) Release flink-connector-jdbc v4.0.0 for Flink 2.0 Yuepeng Pan (Jira)
• 2026/06/22 [jira] [Created] (FLINK-39972) Release flink-connector-jdbc v3.4.0 for Flink 1.20 Chanhae Oh (Jira)
• 2026/06/22 [jira] [Updated] (FLINK-36659) Release flink-connector-jdbc v4.0.0 for Flink 2.0 Yuepeng Pan (Jira)
• 2026/06/22 Re: [PR] [FLINK-39765][cdc-pipeline/mysql] Implement lineage (FLIP-314) support for mysql source connectors [flink-cdc] via GitHub
• 2026/06/22 Re: [PR] [FLINK-39219] [table] Allow connectors to override lineage dataset name [flink] via GitHub
• 2026/06/22 Re: [PR] [FLINK-39327][pipeline-connector/dws]add dws sink pipeline connector [flink-cdc] via GitHub
• 2026/06/22 [jira] [Commented] (FLINK-39968) [Optimization] Reduce redundant AtomicBoolean allocation in MemorySegment to improve construction performance chenqiang (Jira)
• 2026/06/22 [jira] [Comment Edited] (FLINK-39818) Filter org.eclipse.parsson:parsson false positive for Elasticsearch connector reswqa (Jira)
• 2026/06/22 [jira] [Updated] (FLINK-39818) Filter org.eclipse.parsson:parsson false positive for Elasticsearch connector reswqa (Jira)
• 2026/06/22 Re: [PR] [FLINK-37288] Add Google Cloud Spanner dialect and catalog [flink-connector-jdbc] via GitHub
• 2026/06/22 Re: [PR] [BP-2.3][FLINK-39818][ci] Filter org.eclipse.parsson:parsson false positive f… [flink] via GitHub
• 2026/06/22 [jira] [Closed] (FLINK-39966) FlinkRelMdModifiedMonotonicity wrongly reports a non-time-attribute Top-1 Rank as insert-only lincoln lee (Jira)
• 2026/06/22 Re: [PR] [FLINK-39966][table-planner] FlinkRelMdModifiedMonotonicity wrongly reports a non-time-attribute Top-1 Rank as insert-only [flink] via GitHub
• 2026/06/22 [jira] [Updated] (FLINK-39971) Support and Release Connectors for Flink 2.2 Chanhae Oh (Jira)
• 2026/06/22 [jira] [Created] (FLINK-39971) Support and Release Connectors for Flink 2.2 Chanhae Oh (Jira)
• 2026/06/22 Re: [PR] [Flink-39911][historyserver] Support Pluggable Storage Backend for HistoryServer [flink] via GitHub
• 2026/06/22 [jira] [Updated] (FLINK-39970) Kubernetes Operator proceeds with cluster resubmission after Deployment deletion wait timeout, causing AlreadyExists / object-is-being-deleted race ASF GitHub Bot (Jira)
• 2026/06/22 [PR] [FLINK-39970] Retry incomplete JobManager deployment deletion [flink-kubernetes-operator] via GitHub
• 2026/06/22 Re: [PR] [FLINK-39676][docs] Document HTTP query creator option [flink-connector-http] via GitHub
• 2026/06/22 Re: [PR] [FLINK-39510][docs-zh] Translate AI-assisted contribution guidance [flink-web] via GitHub
• 2026/06/22 Re: [PR] [FLINK-39374][Kudu] Rename max buffer size config option [flink-connector-kudu] via GitHub
• 2026/06/22 Re: [PR] [FLINK-39193][Kafka Connector] Use reset strategy for missing specified offsets [flink-connector-kafka] via GitHub
• 2026/06/22 Re: [PR] [FLINK-37288] Add Google Cloud Spanner dialect and catalog [flink-connector-jdbc] via GitHub
• 2026/06/22 Re: [PR] [FLINK-38918][python][kafka connector] support per cluster offset for DynamicKafkaSource in pyflink [flink] via GitHub
• 2026/06/22 Re: [PR] [FLINK-38918][python][kafka connector] support per cluster offset for DynamicKafkaSource in pyflink [flink] via GitHub
• 2026/06/22 [jira] [Updated] (FLINK-39014) Fix the conversion to relational algebra issue in Batch Mode Archit Goyal (Jira)
• 2026/06/22 Re: [PR] [FLINK-39014][table] Fix the conversion to relational algebra issue in Batch Mode [flink] via GitHub
• 2026/06/22 Re: [PR] [FLINK-39014][table] Fix the conversion to relational algebra issue in Batch Mode [flink] via GitHub
• 2026/06/22 [jira] [Updated] (FLINK-39014) Fix the conversion to relational algebra issue in Batch Mode Archit Goyal (Jira)
• 2026/06/22 [jira] [Updated] (FLINK-39014) Fix the conversion to relational algebra issue in Batch Mode Archit Goyal (Jira)
• 2026/06/22 Re: [PR] [FLINK-39014][table] Fix the conversion to relational algebra issue in Batch Mode [flink] via GitHub
• 2026/06/22 Re: [PR] [FLINK-39014][table] Fix the conversion to relational algebra issue in Batch Mode [flink] via GitHub
• 2026/06/22 Re: [PR] [FLINK-39014][table] Fix the conversion to relational algebra issue in Batch Mode [flink] via GitHub
• 2026/06/22 Re: [PR] [FLINK-39014][table] Fix the conversion to relational algebra issue in Batch Mode [flink] via GitHub
• 2026/06/22 Re: [PR] Add GPG key for 2.3.0 release [flink-docker] via GitHub
• 2026/06/22 Re: [PR] [FLINK-38918][python][kafka connector] support per cluster offset for DynamicKafkaSource in pyflink [flink] via GitHub
• 2026/06/22 Re: [PR] Add GPG key for 2.3.0 release [flink-docker] via GitHub
• 2026/06/22 [PR] Release 2.3 dockerfiles [flink-docker] via GitHub
• 2026/06/22 Re: [PR] [FLINK-38918][python][kafka connector] support per cluster offset for DynamicKafkaSource in pyflink [flink] via GitHub
• 2026/06/22 Re: [PR] [FLINK-39944] Make dynamic Kafka metadata refresh resilient [flink-connector-kafka] via GitHub
• 2026/06/22 [PR] Add GPG key for 2.3.0 release [flink-docker] via GitHub
• 2026/06/22 [PR] Add GPG key for 2.3.0 release [flink-docker] via GitHub
• 2026/06/22 Re: [PR] [FLINK-39443][release] Update dev-master to point to 2.4 [flink-docker] via GitHub
• 2026/06/22 Re: [PR] [FLINK-39944] Make dynamic Kafka metadata refresh resilient [flink-connector-kafka] via GitHub
• 2026/06/22 [jira] [Updated] (FLINK-39947) Fix the flaky test case in class TaskExecutorPartitionLifecycleTest Rui Fan (Jira)
• 2026/06/22 Re: [PR] [FLINK-39769][tests][JUnit5 migration] Module: flink-examples-streaming [flink] via GitHub
• 2026/06/22 Re: [PR] [FLINK-39772][tests][JUnit5 migration] Module: flink-fs-tests [flink] via GitHub
• 2026/06/22 Re: [PR] [FLINK-39769][tests][JUnit5 migration] Module: flink-examples-streaming [flink] via GitHub
• 2026/06/22 [jira] [Commented] (FLINK-39137) Add configurable delay between non-empty GetRecords calls in Kinesis source Andreas Bube (Jira)
• 2026/06/22 Re: [PR] [FLINK-39772][tests][JUnit5 migration] Module: flink-fs-tests [flink] via GitHub
• 2026/06/22 Re: [PR] [FLINK-37027][docs] Translate TO_TIMESTAMP_LTZ descriptions [flink] via GitHub
• 2026/06/22 Re: [PR] [FLINK-39772][tests][JUnit5 migration] Module: flink-fs-tests [flink] via GitHub
• 2026/06/22 [jira] [Updated] (FLINK-37027) Chinese document translation for additional TO_TIMESTAMP_LTZ() functions ASF GitHub Bot (Jira)
• 2026/06/22 [PR] [FLINK-37027][docs] Translate TO_TIMESTAMP_LTZ descriptions [flink] via GitHub
• 2026/06/22 [jira] [Created] (FLINK-39970) Kubernetes Operator proceeds with cluster resubmission after Deployment deletion wait timeout, causing AlreadyExists / object-is-being-deleted race Bowen Li (Jira)
• 2026/06/22 Re: [PR] [FLINK-39791][helm] Honor defaultConfiguration.config.yaml and always mount config.yaml [flink-kubernetes-operator] via GitHub
• 2026/06/22 Re: [PR] [FLINK-38918][python][kafka connector] support per cluster offset for DynamicKafkaSource in pyflink [flink] via GitHub
• 2026/06/22 Re: [PR] [FLINK-39954][tests] Relax SinkV2 scaling commit assertion [flink] via GitHub
• 2026/06/22 [PR] [FLINK-38918][python][kafka connector] support per cluster offset for DynamicKafkaSource in pyflink [flink] via GitHub
• 2026/06/22 [jira] [Assigned] (FLINK-38918) support per cluster offset for DynamicKafkaSource in pyflink Bowen Li (Jira)
• 2026/06/22 [jira] [Updated] (FLINK-39944) Dynamic Kafka source cluster removal is not resilient enough ASF GitHub Bot (Jira)
• 2026/06/22 [PR] [FLINK-39944] Make dynamic Kafka metadata refresh resilient [flink-connector-kafka] via GitHub
• 2026/06/22 Re: [PR] [FLINK-34368][fs] Update GCS connector to 3.1.17 [flink] via GitHub
• 2026/06/22 Re: [PR] [FLINK-39769][tests][JUnit5 migration] Module: flink-examples-streaming [flink] via GitHub
• 2026/06/22 [PR] [FLINK-34368][fs] Update GCS connector to 3.1.17 [flink] via GitHub
• 2026/06/22 [jira] [Updated] (FLINK-38575) Checkpoint Race Condition in KuduSourceEnumerator Ferenc Csaky (Jira)
• 2026/06/22 Re: [PR] [FLINK-39772][tests][JUnit5 migration] Module: flink-fs-tests [flink] via GitHub
• 2026/06/22 Re: [PR] [FLINK-39772][tests][JUnit5 migration] Module: flink-fs-tests [flink] via GitHub
• 2026/06/22 Re: [PR] [FLINK-39772][tests][JUnit5 migration] Module: flink-fs-tests [flink] via GitHub
• 2026/06/22 [jira] [Updated] (FLINK-33064) Improve the error message when the lookup source is used as the scan source David Anderson (Jira)
• 2026/06/22 [jira] [Updated] (FLINK-31951) Mix schema record source creates corrupt record David Anderson (Jira)
• 2026/06/22 Re: [PR] [FLINK-39772][tests][JUnit5 migration] Module: flink-fs-tests [flink] via GitHub
• 2026/06/22 Re: [PR] [FLINK-39772][tests][JUnit5 migration] Module: flink-fs-tests [flink] via GitHub
• 2026/06/22 [jira] [Updated] (FLINK-30629) ClientHeartbeatTest.testJobRunningIfClientReportHeartbeat is unstable David Anderson (Jira)
• 2026/06/22 Re: [PR] [FLINK-39772][tests][JUnit5 migration] Module: flink-fs-tests [flink] via GitHub
• 2026/06/22 Re: [PR] [FLINK-39772][tests][JUnit5 migration] Module: flink-fs-tests [flink] via GitHub
• 2026/06/22 [jira] [Updated] (FLINK-30166) Refactor tests that use the deprecated StreamingFileSink instead of FileSink David Anderson (Jira)
• 2026/06/22 [jira] [Updated] (FLINK-28440) EventTimeWindowCheckpointingITCase failed with restore David Anderson (Jira)
• 2026/06/22 Re: [PR] [FLINK-39772][tests][JUnit5 migration] Module: flink-fs-tests [flink] via GitHub
• 2026/06/22 [jira] [Updated] (FLINK-22826) flink sql1.13.1 causes data loss based on change log stream data join David Anderson (Jira)
• 2026/06/22 [jira] [Updated] (FLINK-15470) Remove YARN magic properties file David Anderson (Jira)
• 2026/06/22 Re: [PR] [FLINK-39769][tests][JUnit5 migration] Module: flink-examples-streaming [flink] via GitHub
• 2026/06/22 [jira] [Resolved] (FLINK-39452) [release-2.3] Verify that no exclusions were erroneously added to the japicmp plugin David Anderson (Jira)
• 2026/06/22 [jira] [Resolved] (FLINK-39445) [release-2.3] Select executing release manager David Anderson (Jira)
• 2026/06/22 [jira] [Resolved] (FLINK-37162) Add Data Sink Documentation David Anderson (Jira)
• 2026/06/22 Re: [PR] [FLINK-39954][tests] Relax SinkV2 scaling commit assertion [flink] via GitHub
• 2026/06/22 [jira] [Resolved] (FLINK-39447) [release-2.3] Prepare RC0 release David Anderson (Jira)
• 2026/06/22 [jira] [Resolved] (FLINK-39450) [release-2.3] Triage release blockers in JIRA David Anderson (Jira)
• 2026/06/22 [jira] [Updated] (FLINK-37690) Fix flaky Kudu test table datagen ASF GitHub Bot (Jira)
• 2026/06/22 [jira] [Resolved] (FLINK-39448) [release-2.3] Review release notes in JIRA David Anderson (Jira)
• 2026/06/22 [PR] [FLINK-37690] Fix Kudu test table create/cleanup [flink-connector-kudu] via GitHub
• 2026/06/22 Re: [PR] [FLINK-39957][table] Support EXPLAIN of CREATE [OR ALTER] MATERIALIZED TABLE [flink] via GitHub
• 2026/06/22 Re: [PR] [FLINK-39957][table] Support EXPLAIN of CREATE [OR ALTER] MATERIALIZED TABLE [flink] via GitHub
• 2026/06/22 Re: [PR] [FLINK-39957][table] Support EXPLAIN of CREATE [OR ALTER] MATERIALIZED TABLE [flink] via GitHub
• 2026/06/22 Re: [PR] [FLINK-39957][table] Support EXPLAIN of CREATE [OR ALTER] MATERIALIZED TABLE [flink] via GitHub
• 2026/06/22 Re: [PR] [FLINK-39957][table] Support EXPLAIN of CREATE [OR ALTER] MATERIALIZED TABLE [flink] via GitHub
• 2026/06/22 [PR] [FLINK-39957][table] Support EXPLAIN of CREATE [OR ALTER] MATERIALIZED TABLE [flink] via GitHub
• 2026/06/22 [jira] [Updated] (FLINK-39957) Support EXPLAIN CREATE [OR ALTER] MATERIALIZED TABLE statements ASF GitHub Bot (Jira)
• 2026/06/22 Re: [PR] [FLINK-31849] Adds basic CRD validations [flink-kubernetes-operator] via GitHub
• 2026/06/22 Re: [PR] docs: fix 8 subject-verb agreement errors in Javadoc comments [flink-connector-kafka] via GitHub
• 2026/06/22 [PR] docs: fix 8 subject-verb agreement errors in Javadoc comments [flink-connector-kafka] via GitHub
• 2026/06/22 Re: [PR] [hotfix][BP-2.2] Add HTTP connector 1.0 docs [flink] via GitHub
• 2026/06/22 Re: [PR] [hotfix] Add HTTP connector 1.0 docs [flink] via GitHub
• 2026/06/22 Re: [PR] [FLINK-31849] Adds basic CRD validations [flink-kubernetes-operator] via GitHub
• 2026/06/22 [jira] [Commented] (FLINK-31849) Enforce some some simple validation directly through the CRD Santwana Verma (Jira)
• 2026/06/22 [PR] [hotfix][BP-2.2] Add HTTP connector 1.0 docs [flink] via GitHub
• 2026/06/22 Re: [PR] [FLINK-39954][tests] Relax SinkV2 scaling commit assertion [flink] via GitHub
• 2026/06/22 Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
• 2026/06/22 [jira] [Updated] (FLINK-39193) SpecifiedOffsetsInitializer can fail if the caller passes a non-empty but incomplete specific-offset map. ASF GitHub Bot (Jira)
• 2026/06/22 [jira] [Commented] (FLINK-39193) SpecifiedOffsetsInitializer can fail if the caller passes a non-empty but incomplete specific-offset map. Qiu Yanjun (Jira)
• 2026/06/22 Re: [PR] [FLINK-39193][Kafka Connector] Use reset strategy for missing specified offsets [flink-connector-kafka] via GitHub
• 2026/06/22 [PR] [FLINK-39193][Kafka Connector] Use reset strategy for missing specified offsets [flink-connector-kafka] via GitHub
• 2026/06/22 Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
• 2026/06/22 Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
• 2026/06/22 Re: [PR] [FLINK-39009] Support PostgreSQL unnest insert in dynamic table. [flink-connector-jdbc] via GitHub
• 2026/06/22 [PR] [hotfix] Add HTTP connector 1.0 docs [flink] via GitHub
• 2026/06/22 Re: [PR] [FLINK-37404, FLINK-36334][API / Core] Reenable Migration Tests for Filnk 2.x [flink] via GitHub
• 2026/06/22 Re: [PR] [FLINK-37834] Flink JDBC support ClickHouse Dialect [flink-connector-jdbc] via GitHub
• 2026/06/22 [jira] [Updated] (FLINK-31849) Enforce some some simple validation directly through the CRD ASF GitHub Bot (Jira)
• 2026/06/22 [jira] [Commented] (FLINK-39954) SinkV2ITCase over-asserts commit multiplicity under unaligned checkpoints Qiu Yanjun (Jira)
• 2026/06/22 [PR] [FLINK-31849] Adds basic CRD validations [flink-kubernetes-operator] via GitHub
• 2026/06/22 Re: [PR] [FLINK-37288] Add Google Cloud Spanner dialect and catalog [flink-connector-jdbc] via GitHub
• 2026/06/22 [jira] [Updated] (FLINK-39954) SinkV2ITCase over-asserts commit multiplicity under unaligned checkpoints ASF GitHub Bot (Jira)
• 2026/06/22 [jira] [Updated] (FLINK-38498) Support Mysql Timestamp and Postgres Timestamp_tz type. Yuepeng Pan (Jira)
• 2026/06/22 [jira] [Commented] (FLINK-38498) Support Mysql Timestamp and Postgres Timestamp_tz type. Yuepeng Pan (Jira)
• 2026/06/22 [PR] [FLINK-39954][tests] Relax SinkV2 scaling commit assertion [flink] via GitHub
• 2026/06/22 Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
• 2026/06/22 Re: [PR] [FLINK-38498] Support Mysql Timestamp and Postgres Timestamp_tz type. [flink-connector-jdbc] via GitHub
• 2026/06/22 [jira] [Updated] (FLINK-38498) Support Mysql Timestamp and Postgres Timestamp_tz type. Yuepeng Pan (Jira)
• 2026/06/22 Re: [PR] [FLINK-38498] Support Mysql Timestamp and Postgres Timestamp_tz type. [flink-connector-jdbc] via GitHub
• 2026/06/22 Re: [PR] [FLINK-37404, FLINK-36334][API / Core] Reenable Migration Tests for Filnk 2.x [flink] via GitHub
• 2026/06/22 Re: [PR] [hotfix][JDBC] Fix db2 Db2Dialect error. [flink-connector-jdbc] via GitHub
• 2026/06/22 Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
• 2026/06/22 [jira] [Updated] (FLINK-37404) Reenable Migration Tests for Filnk 2.x ASF GitHub Bot (Jira)
• 2026/06/22 [PR] [FLINK-37404, FLINK-36334][API / Core] Reenable Migration Tests for Filnk 2.x [flink] via GitHub
• 2026/06/22 Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
• 2026/06/22 [jira] [Closed] (FLINK-38101) Support SI Format for CPU resources Santwana Verma (Jira)
• 2026/06/22 [jira] [Comment Edited] (FLINK-38101) Support SI Format for CPU resources Santwana Verma (Jira)
• 2026/06/22 [jira] [Resolved] (FLINK-39817) Upgrade Calcite version to 1.39.0 Sergey Nuyanzin (Jira)
• 2026/06/22 [jira] [Commented] (FLINK-39817) Upgrade Calcite version to 1.39.0 Sergey Nuyanzin (Jira)
• 2026/06/22 [jira] [Assigned] (FLINK-39193) SpecifiedOffsetsInitializer can fail if the caller passes a non-empty but incomplete specific-offset map. Bowen Li (Jira)
• 2026/06/22 Re: [PR] [FLINK-39817][table] Upgrade Calcite version to 1.39.0 [flink] via GitHub
• 2026/06/22 Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
• 2026/06/22 [jira] [Commented] (FLINK-38101) Support SI Format for CPU resources Santwana Verma (Jira)
• 2026/06/22 [jira] [Commented] (FLINK-39137) Add configurable delay between non-empty GetRecords calls in Kinesis source Jing-Jia Hung (Jira)
• 2026/06/22 Re: [PR] [FLINK-39674][formats] Upgrade Confluent Schema Registry client [flink] via GitHub
• 2026/06/22 [jira] [Commented] (FLINK-39954) SinkV2ITCase over-asserts commit multiplicity under unaligned checkpoints Qiu Yanjun (Jira)
• 2026/06/22 Re: [PR] [hotfix] Fix db2 Db2Dialect error [flink-connector-jdbc] via GitHub
• 2026/06/22 Re: [PR] [hotfix] Fix db2 Db2Dialect error [flink-connector-jdbc] via GitHub
• 2026/06/22 [PR] [hotfix][JDBC] Fix db2 Db2Dialect error. [flink-connector-jdbc] via GitHub
• 2026/06/22 [jira] [Commented] (FLINK-39969) use the same SSL protcol and algorithms on all the flink services and all clients Jira
• 2026/06/22 Re: [PR] Move setLastReconciledSpec to after successful transition start [flink-kubernetes-operator] via GitHub
• 2026/06/22 [jira] [Created] (FLINK-39969) use the same SSL protcol and algorithms on all the flink services and all clients Jira
• 2026/06/22 [PR] Rebuild website [flink-web] via GitHub
• 2026/06/22 Re: [PR] Rebuild website [flink-web] via GitHub
• 2026/06/22 Re: [PR] Move setLastReconciledSpec to after successful transition start [flink-kubernetes-operator] via GitHub
• 2026/06/22 Re: [PR] [FLINK-39637][state] Add filter pushdown support for savepoint connector [flink] via GitHub
• 2026/06/22 [jira] [Commented] (FLINK-39193) SpecifiedOffsetsInitializer can fail if the caller passes a non-empty but incomplete specific-offset map. Qiu Yanjun (Jira)
• 2026/06/22 Re: [PR] [FLINK-39674][formats] Upgrade Confluent Schema Registry client [flink] via GitHub
• 2026/06/22 Re: [PR] [FLINK-39966][table-planner] FlinkRelMdModifiedMonotonicity wrongly reports a non-time-attribute Top-1 Rank as insert-only [flink] via GitHub
• 2026/06/22 Re: [PR] Add HTTP Connector 1.0 [flink-web] via GitHub
• 2026/06/22 [jira] [Commented] (FLINK-39674) flink-avro-confluent-registry uses an obsolete schema registry client Qiu Yanjun (Jira)
• 2026/06/22 [jira] [Updated] (FLINK-39966) FlinkRelMdModifiedMonotonicity wrongly reports a non-time-attribute Top-1 Rank as insert-only ASF GitHub Bot (Jira)
• 2026/06/22 [PR] [FLINK-39966][table-planner] FlinkRelMdModifiedMonotonicity wrongly reports a non-time-attribute Top-1 Rank as insert-only [flink] via GitHub
• 2026/06/22 [jira] [Updated] (FLINK-39674) flink-avro-confluent-registry uses an obsolete schema registry client ASF GitHub Bot (Jira)
• 2026/06/22 [PR] [FLINK-39674][formats] Upgrade Confluent Schema Registry client [flink] via GitHub
• 2026/06/22 Re: [PR] [FLINK-39556][table] Make file path optional in COMPILE PLAN to return plan inline as a result set [flink] via GitHub
• 2026/06/22 Re: [PR] [FLINK-39556][table] Make file path optional in COMPILE PLAN to return plan inline as a result set [flink] via GitHub
• 2026/06/22 [jira] [Updated] (FLINK-39374) Rename KuduWriterConfig.maxBufferSize to maxMutationBufferOps ASF GitHub Bot (Jira)
• 2026/06/22 [jira] [Commented] (FLINK-39374) Rename KuduWriterConfig.maxBufferSize to maxMutationBufferOps Qiu Yanjun (Jira)
• 2026/06/22 [PR] [FLINK-39374][Kudu] Rename max buffer size config option [flink-connector-kudu] via GitHub
• 2026/06/22 [jira] [Updated] (FLINK-39967) FlinkStateSnapshot with default backoffLimit=-1 (documented as "unlimited retries") never retries and fails immediately on first error ASF GitHub Bot (Jira)
• 2026/06/22 [jira] [Closed] (FLINK-39967) FlinkStateSnapshot with default backoffLimit=-1 (documented as "unlimited retries") never retries and fails immediately on first error Gyula Fora (Jira)
• 2026/06/22 Re: [PR] [FLINK-39967] Fix `backoffLimit=-1` to mean unlimited retries in FlinkStateSnapshot [flink-kubernetes-operator] via GitHub
• 2026/06/22 [jira] [Commented] (FLINK-39374) Rename KuduWriterConfig.maxBufferSize to maxMutationBufferOps Marton Greber (Jira)
• 2026/06/22 Re: [PR] [FLINK-39866][table] Remove dead `KEYVALUE` code from `SqlFunctionUtils` and `StringCallGen` [flink] via GitHub
• 2026/06/22 Re: [PR] [FLINK-39215] [python] Clean up PythonDriver tmp dir on launch failure [flink] via GitHub
• 2026/06/22 [jira] [Commented] (FLINK-39374) Rename KuduWriterConfig.maxBufferSize to maxMutationBufferOps Qiu Yanjun (Jira)
• 2026/06/22 Re: [PR] [FLINK-39769][tests][JUnit5 migration] Module: flink-examples-streaming [flink] via GitHub
• 2026/06/22 Re: [PR] [FLINK-39772][tests][JUnit5 migration] Module: flink-fs-tests [flink] via GitHub
• 2026/06/22 [jira] [Commented] (FLINK-39215) Fix tmp dir leak in PythonDriver when launchPy4jPythonClient fails Qiu Yanjun (Jira)
• 2026/06/22 [PR] [FLINK-39215] [python] Clean up PythonDriver tmp dir on launch failure [flink] via GitHub
• 2026/06/22 [jira] [Updated] (FLINK-39215) Fix tmp dir leak in PythonDriver when launchPy4jPythonClient fails ASF GitHub Bot (Jira)
• 2026/06/22 Re: [PR] [FLINK-39728] Fix pauseOrResumeSplits race with unassigned partitions [flink-connector-kafka] via GitHub
• 2026/06/22 [jira] [Updated] (FLINK-39968) [Optimization] Reduce redundant AtomicBoolean allocation in MemorySegment to improve construction performance yyka (Jira)
• 2026/06/22 [jira] [Updated] (FLINK-39968) [Optimization] Reduce redundant AtomicBoolean allocation in MemorySegment to improve construction performance yyka (Jira)
• 2026/06/22 [jira] [Assigned] (FLINK-39967) FlinkStateSnapshot with default backoffLimit=-1 (documented as "unlimited retries") never retries and fails immediately on first error Gyula Fora (Jira)
• 2026/06/22 [jira] [Created] (FLINK-39968) [Optimization] Reduce redundant AtomicBoolean allocation in MemorySegment to improve construction performance yyka (Jira)
• 2026/06/22 Re: [PR] [FLINK-39866][table] Remove dead `KEYVALUE` code from `SqlFunctionUtils` and `StringCallGen` [flink] via GitHub
• 2026/06/22 [jira] [Updated] (FLINK-39967) FlinkStateSnapshot with default backoffLimit=-1 (documented as "unlimited retries") never retries and fails immediately on first error Santwana Verma (Jira)
• 2026/06/22 [jira] [Commented] (FLINK-39967) FlinkStateSnapshot with default backoffLimit=-1 (documented as "unlimited retries") never retries and fails immediately on first error Santwana Verma (Jira)

• Earlier messages
• Later messages