issues  

Messages by Date

• 2026/10/24 Re: [PR] [FLINK-40586][Connectors/Kafka] Clear the no-more-splits dedup set on a metadata change [flink-connector-kafka] via GitHub
• 2026/10/24 Re: [PR] [FLINK-41056][table] Keep non-compact decimals with unscaled value fitting in a long as long to avoid BigDecimal on read, add, subtract, cast and deserialize [flink] via GitHub
• 2026/10/24 [jira] [Updated] (FLINK-41060) Exactly-once JdbcSink commits its XA branch at the checkpoint barrier Martijn Visser (Jira)
• 2026/10/24 [jira] [Updated] (FLINK-41101) discoverAndRollbackOnRecovery never rolls back a transaction against a real driver Martijn Visser (Jira)
• 2026/10/24 [jira] [Updated] (FLINK-41060) Exactly-once JdbcSink commits its XA branch at the checkpoint barrier Martijn Visser (Jira)
• 2026/10/24 [jira] [Updated] (FLINK-41060) Exactly-once JdbcSink commits its XA branch at the checkpoint barrier Martijn Visser (Jira)
• 2026/10/24 Re: [PR] [FLINK-41117][ci] Bump ubuntu to 26 in Azure and GHA [flink] via GitHub
• 2026/10/24 Re: [PR] [FLINK-40958][core] `BinaryVariantInternalBuilder.appendVariantImpl` might lead to `StackOverflow` [flink] via GitHub
• 2026/10/24 Re: [PR] [FLINK-40846][tests] Remove the REQUIREMENTS_CHECK_DELAY override from EventTimeWindowCheckpointingITCase [flink] via GitHub
• 2026/10/24 [jira] [Updated] (FLINK-40846) Remove the REQUIREMENTS_CHECK_DELAY override from EventTimeWindowCheckpointingITCase ASF GitHub Bot (Jira)
• 2026/10/24 [jira] [Created] (FLINK-41123) [release-2.4] Prepare RC0 release Yuepeng Pan (Jira)
• 2026/10/24 Re: [PR] [FLINK-40586][Connectors/Kafka] Clear the no-more-splits dedup set on a metadata change [flink-connector-kafka] via GitHub
• 2026/10/24 [jira] [Resolved] (FLINK-41120) [release-2.4] Create new version in Jira Yuepeng Pan (Jira)
• 2026/10/24 [jira] [Updated] (FLINK-40574) Update SLF4J from 1.7.36 to 2.x Martijn Visser (Jira)
• 2026/10/24 Re: [PR] [FLINK-40574][build] Update SLF4J from 1.7.36 to 2.0.20 [flink] via GitHub
• 2026/10/24 [jira] [Resolved] (FLINK-40621) FlinkKafkaInternalProducerITCase.testResetInnerTransactionIfFinalizingTransactionFailed fails with InvalidProducerEpochException instead of ProducerFencedException Martijn Visser (Jira)
• 2026/10/24 [jira] [Assigned] (FLINK-40621) FlinkKafkaInternalProducerITCase.testResetInnerTransactionIfFinalizingTransactionFailed fails with InvalidProducerEpochException instead of ProducerFencedException Martijn Visser (Jira)
• 2026/10/24 Re: [PR] [FLINK-40621][Connectors/Kafka] test: Flush before fencing in producer reset test [flink-connector-kafka] via GitHub
• 2026/10/24 [jira] [Assigned] (FLINK-41131) Release Testing Instructions: FLIP-485: Add UDF Metrics Yuepeng Pan (Jira)
• 2026/10/24 [jira] [Assigned] (FLINK-41130) [Umbrella] Test Flink Release 2.4 Yuepeng Pan (Jira)
• 2026/10/24 Re: [PR] [FLINK-40621][Connectors/Kafka] test: Flush before fencing in producer reset test [flink-connector-kafka] via GitHub
• 2026/10/24 [jira] [Created] (FLINK-41131) Release Testing Instructions: FLIP-485: Add UDF Metrics Yuepeng Pan (Jira)
• 2026/10/24 [jira] [Updated] (FLINK-40838) Add a DataStream end-to-end test for the Confluent Schema Registry format Martijn Visser (Jira)
• 2026/10/24 Re: [PR] Bump org.apache.logging.log4j:log4j-core from 2.17.1 to 2.25.3 in /flink-connector-cassandra [flink-connector-cassandra] via GitHub
• 2026/10/24 [jira] [Resolved] (FLINK-40817) Remove the deprecated configuration keys from the flink-yarn module. Yuepeng Pan (Jira)
• 2026/10/24 Re: [PR] [FLINK-40817][yarn] Remove the deprecated configuration keys from the flink-yarn module. [flink] via GitHub
• 2026/10/24 Re: [PR] [FLINK-40817][yarn] Remove the deprecated configuration keys from the flink-yarn module. [flink] via GitHub
• 2026/10/24 [jira] [Created] (FLINK-41128) [release-2.4] Verify that no exclusions were erroneously added to the japicmp plugin Yuepeng Pan (Jira)
• 2026/10/24 [jira] [Assigned] (FLINK-41120) [release-2.4] Create new version in Jira Yuepeng Pan (Jira)
• 2026/10/24 [jira] [Updated] (FLINK-41120) [release-2.4] Create new version in Jira Yuepeng Pan (Jira)
• 2026/10/24 [jira] [Updated] (FLINK-41130) [Umbrella] Test Flink Release 2.4 Yuepeng Pan (Jira)
• 2026/10/24 [jira] [Updated] (FLINK-41130) [Umbrella] Test Flink Release 2.4 Yuepeng Pan (Jira)
• 2026/10/24 [jira] [Created] (FLINK-41130) [Umbrella] Test Flink Release 2.4 Yuepeng Pan (Jira)
• 2026/10/24 [jira] [Updated] (FLINK-41130) [Umbrella] Test Flink Release 2.4 Yuepeng Pan (Jira)
• 2026/10/24 [jira] [Commented] (FLINK-41119) Prepare Flink 2.4 release Yuepeng Pan (Jira)
• 2026/10/24 Re: [PR] [FLINK-40958][core] `BinaryVariantInternalBuilder.appendVariantImpl` might lead to `StackOverflow` [flink] via GitHub
• 2026/10/24 [jira] [Created] (FLINK-41127) [release-2.4] Review and update documentation Yuepeng Pan (Jira)
• 2026/10/24 [jira] [Created] (FLINK-41126) [release-2.4] Triage release blockers in JIRA Yuepeng Pan (Jira)
• 2026/10/24 [jira] [Created] (FLINK-41124) [release-2.4] Review release notes in JIRA Yuepeng Pan (Jira)
• 2026/10/24 [jira] [Created] (FLINK-41125) [release-2.4] Cross-team testing Yuepeng Pan (Jira)
• 2026/10/24 [PR] [FLINK-40958][core] `BinaryVariantInternalBuilder.appendVariantImpl` might lead to `StackOverflow` [flink] via GitHub
• 2026/10/24 [jira] [Updated] (FLINK-41122) [release-2.4] Create release branch Yuepeng Pan (Jira)
• 2026/10/24 [jira] [Updated] (FLINK-41122) [release-2.4] Create release branch Yuepeng Pan (Jira)
• 2026/10/24 [jira] [Assigned] (FLINK-41122) [release-2.4] Create release branch Yuepeng Pan (Jira)
• 2026/10/24 [jira] [Updated] (FLINK-41121) [release-2.4] Select executing release manager Yuepeng Pan (Jira)
• 2026/10/24 [jira] [Created] (FLINK-41120) [release-2.4] Create new version in Jira Yuepeng Pan (Jira)
• 2026/10/24 [jira] [Created] (FLINK-41119) Prepare Flink 2.4 release Yuepeng Pan (Jira)
• 2026/10/24 Re: [PR] [FLINK-40586][Connectors/Kafka] Clear the no-more-splits dedup set on a metadata change [flink-connector-kafka] via GitHub
• 2026/10/24 [jira] [Updated] (FLINK-40710) Dynamic Kafka Source assigns duplicate partition owners after local failover Martijn Visser (Jira)
• 2026/10/24 Re: [PR] [FLINK-40817][yarn] Remove the deprecated configuration keys from the flink-yarn module. [flink] via GitHub
• 2026/10/24 [jira] [Commented] (FLINK-41117) Move CI to ubuntu 26 Sergey Nuyanzin (Jira)
• 2026/10/24 [jira] [Resolved] (FLINK-31006) job is not finished when using pipeline mode to run bounded source like kafka Martijn Visser (Jira)
• 2026/10/24 Re: [PR] [FLINK-31006][Connectors/Kafka] Signal no more splits after a restored bounded enumerator finds no partition changes [flink-connector-kafka] via GitHub
• 2026/10/24 [jira] [Commented] (FLINK-41049) CI jobs fail when the downloaded Maven wrapper jar does not pass its SHA-256 check Sergey Nuyanzin (Jira)
• 2026/10/24 [jira] [Commented] (FLINK-41075) Kill each e2e timeout watchdog when its command ends Sergey Nuyanzin (Jira)
• 2026/10/24 [jira] [Resolved] (FLINK-41075) Kill each e2e timeout watchdog when its command ends Sergey Nuyanzin (Jira)
• 2026/10/24 Re: [PR] [FLINK-41075][ci] Kill each e2e timeout watchdog when its command ends [flink] via GitHub
• 2026/10/24 Re: [PR] [FLINK-41118][tests] Migrate EventTimeWindowCheckpointingITCase to Source V2 and remove FailingSource [flink] via GitHub
• 2026/10/24 Re: [PR] [docs] Migrate documentation from Hugo to Docusaurus [flink-cdc] via GitHub
• 2026/10/24 [jira] [Updated] (FLINK-41118) Migrate EventTimeWindowCheckpointingITCase to FailingCheckpointedSource and remove FailingSource ASF GitHub Bot (Jira)
• 2026/10/24 [PR] [FLINK-41118][tests] Migrate EventTimeWindowCheckpointingITCase to Source V2 and remove FailingSource [flink] via GitHub
• 2026/10/24 [jira] [Created] (FLINK-41118) Migrate EventTimeWindowCheckpointingITCase to FailingCheckpointedSource and remove FailingSource Martijn Visser (Jira)
• 2026/10/24 [jira] [Updated] (FLINK-41117) Move CI to ubuntu 26 ASF GitHub Bot (Jira)
• 2026/10/24 [jira] [Created] (FLINK-41117) Move CI to ubuntu 26 Sergey Nuyanzin (Jira)
• 2026/10/24 Re: [PR] [FLINK-33020][ci] OpensearchSinkTest.testAtLeastOnceSink timed out [flink-connector-opensearch] via GitHub
• 2026/10/24 Re: [I] [Doc][Umbrella] Walk through documentation and validate documented functionality for 0.4 [flink-agents] via GitHub
• 2026/10/24 Re: [I] [Doc] Walkthrough findings for Setup, multi-Agent Quickstart and Flink integration [flink-agents] via GitHub
• 2026/10/24 Re: [PR] [runtime][java] Preserve an existing KeyedStream's business key when no key selector is given [flink-agents] via GitHub
• 2026/10/24 Re: [PR] [hotfix][ci] Reduce test logs and update Java IT and ReAct tests [flink-agents] via GitHub
• 2026/10/24 [jira] [Updated] (FLINK-28596) Support writing arrays to postgres array columns in Flink SQL JDBC connector ASF GitHub Bot (Jira)
• 2026/10/24 [PR] [FLINK-28596][jdbc] Support writing ARRAY values in the PostgreSQL dialect [flink-connector-jdbc] via GitHub
• 2026/10/24 Re: [PR] [FLINK-41116][Connectors/Kafka] Upgrade kafka-clients to 4.4.0 [flink-connector-kafka] via GitHub
• 2026/10/24 [jira] [Updated] (FLINK-41116) Connectors/Kafka: Upgrade kafka-clients to 4.4.0 Purushottam Sinha (Jira)
• 2026/10/24 [jira] [Commented] (FLINK-28596) Support writing arrays to postgres array columns in Flink SQL JDBC connector Tomoyuki NAKAMURA (Jira)
• 2026/10/24 [jira] [Updated] (FLINK-41116) Connectors/Kafka: Upgrade kafka-clients to 4.4.0 ASF GitHub Bot (Jira)
• 2026/10/24 [PR] [FLINK-41116][Connectors/Kafka] Upgrade kafka-clients to 4.4.0 [flink-connector-kafka] via GitHub
• 2026/10/24 [jira] [Created] (FLINK-41116) Connectors/Kafka: Upgrade kafka-clients to 4.4.0 Purushottam Sinha (Jira)
• 2026/10/23 Re: [PR] [FLINK-41110][core] Compare UTF-8 bytes to find VARIANT object fields [flink] via GitHub
• 2026/10/23 [jira] [Commented] (FLINK-40135) [PyFlink] Prevent Beam state access after runner shutdown Bowen Li (Jira)
• 2026/10/23 [jira] [Resolved] (FLINK-40135) [PyFlink] Prevent Beam state access after runner shutdown Bowen Li (Jira)
• 2026/10/23 Re: [PR] [FLINK-40135][python] Prevent Beam state access after runner shutdown [flink] via GitHub
• 2026/10/23 [jira] [Updated] (FLINK-41100) DynamicKafkaSource shares one split output between partitions whose split ids collide ASF GitHub Bot (Jira)
• 2026/10/23 Re: [PR] [FLINK-41100][Connectors/Kafka] Make dynamic source split ids unique per partition [flink-connector-kafka] via GitHub
• 2026/10/23 [PR] [FLINK-41100][Connectors/Kafka] Make dynamic source split ids unique per partition [flink-connector-kafka] via GitHub
• 2026/10/23 [PR] [FLINK-41051][jdbc] Report the configured table name in source lineage [flink-connector-jdbc] via GitHub
• 2026/10/23 [jira] [Updated] (FLINK-40873) Fix overlapping config key prefixes in the operator ASF GitHub Bot (Jira)
• 2026/10/23 [jira] [Updated] (FLINK-41051) JDBC Table source and lookup function derive the lineage dataset name by parsing SQL ASF GitHub Bot (Jira)
• 2026/10/23 [PR] [FLINK-40873][operator] Remove overlapping config key prefixes [flink-kubernetes-operator] via GitHub
• 2026/10/23 Re: [PR] [runtime][java] Preserve an existing KeyedStream's business key when no key selector is given [flink-agents] via GitHub
• 2026/10/23 [jira] [Commented] (FLINK-41100) DynamicKafkaSource shares one split output between partitions whose split ids collide yongfu.gao (Jira)
• 2026/10/23 [jira] [Commented] (FLINK-41051) JDBC Table source and lookup function derive the lineage dataset name by parsing SQL yongfu.gao (Jira)
• 2026/10/23 Re: [PR] [FLINK-40135][python] Prevent Beam state access after runner shutdown [flink] via GitHub
• 2026/10/23 Re: [PR] [FLINK-40135][python] Prevent Beam state access after runner shutdown [flink] via GitHub
• 2026/10/23 Re: [PR] [FLINK-41090][runtime] Close the operator coordinators of uninitialized vertices on dispose [flink] via GitHub
• 2026/10/23 [PR] [FLINK-41090][runtime] Close the operator coordinators of uninitialized vertices on dispose [flink] via GitHub
• 2026/10/23 [jira] [Updated] (FLINK-41090) Operator coordinators of uninitialized vertices are never closed ASF GitHub Bot (Jira)
• 2026/10/23 Re: [PR] [FLINK-41115][runtime] Isolate adaptive graph recovery from IO [flink] via GitHub
• 2026/10/23 [jira] [Updated] (FLINK-41115) Checkpoint cleanup can starve AdaptiveScheduler execution-graph creation ASF GitHub Bot (Jira)
• 2026/10/23 Re: [PR] [FLINK-40747][jdbc] PreparedSplitterEnumerator.of(sql) yields one split [flink-connector-jdbc] via GitHub
• 2026/10/23 Re: [PR] [FLINK-40196][python] Add missing-value handling to DataFrame API [flink] via GitHub
• 2026/10/23 Re: [PR] [FLINK-40779][connector-jdbc] Snapshot splitter state together with its splits [flink-connector-jdbc] via GitHub
• 2026/10/23 [jira] [Resolved] (FLINK-40747) PreparedSplitterEnumerator.of(sqlTemplate) produces no split, the source reads nothing Martijn Visser (Jira)
• 2026/10/23 [jira] [Resolved] (FLINK-40779) JdbcSourceEnumerator snapshots splitter state ahead of the splits it has handled Martijn Visser (Jira)
• 2026/10/23 [PR] [FLINK-41115][runtime] Isolate adaptive graph recovery from IO [flink] via GitHub
• 2026/10/23 Re: [PR] [FLINK-41088][Connectors/Kafka] Key recovery reports by partition [flink-connector-kafka] via GitHub
• 2026/10/23 Re: [PR] [FLINK-40779][connector-jdbc] Snapshot splitter state together with its splits [flink-connector-jdbc] via GitHub
• 2026/10/23 [jira] [Resolved] (FLINK-37288) Add Google Cloud Spanner dialect and catalog Martijn Visser (Jira)
• 2026/10/23 Re: [PR] [FLINK-37288] Add Google Cloud Spanner dialect and catalog [flink-connector-jdbc] via GitHub
• 2026/10/23 [jira] [Resolved] (FLINK-41088) DynamicKafkaSource loses or rejects splits whose formatted split ids collide Martijn Visser (Jira)
• 2026/10/23 [jira] [Created] (FLINK-41115) Checkpoint cleanup can starve AdaptiveScheduler execution-graph creation David Peacock (Jira)
• 2026/10/23 Re: [PR] [FLINK-40604][datastream] Route expired async retry results through timeout handler [flink] via GitHub
• 2026/10/23 Re: [PR] [hotfix] Update copyright year to 2026 [flink-connector-cassandra] via GitHub
• 2026/10/23 [jira] [Resolved] (FLINK-40121) Update Flink Connector Kafka to use Flink 2.3 Martijn Visser (Jira)
• 2026/10/23 Re: [PR] [FLINK-40121][Connectors/Kafka] Build and test against Flink 2.3 [flink-connector-kafka] via GitHub
• 2026/10/23 Re: [PR] [FLINK-41049][ci] Make pre-downloaded Maven usable by the only-script Maven wrapper [flink] via GitHub
• 2026/10/23 Re: [PR] [hotfix] Update copyright year to 2026 [flink-connector-cassandra] via GitHub
• 2026/10/23 Re: [PR] [FLINK-41049][ci] Make pre-downloaded Maven usable by the only-script Maven wrapper [flink] via GitHub
• 2026/10/23 [jira] [Resolved] (FLINK-41112) Support Flink 1.20 in the Cassandra connector Martijn Visser (Jira)
• 2026/10/23 Re: [PR] [FLINK-41112][Connectors/Cassandra] Support Flink 1.20 [flink-connector-cassandra] via GitHub
• 2026/10/23 [PR] [FLINK-41087][table] Build the PARSE_JSON error only where PARSE_JSON rethrows [flink] via GitHub
• 2026/10/23 [PR] [FLINK-41066][table] Handle upsert inputs in multi-way joins [flink] via GitHub
• 2026/10/23 [jira] [Updated] (FLINK-41104) MapState.contains() returns false for an existing key whose value is None Dian Fu (Jira)
• 2026/10/23 [jira] [Commented] (FLINK-41108) PyFlink namespace merges leave stale cached values for TTL-enabled ListState Sangkyoon Nam (Jira)
• 2026/10/23 [jira] [Commented] (FLINK-41103) ValueState.update(None) attempts to serialize None instead of clearing the state Sangkyoon Nam (Jira)
• 2026/10/23 Re: [PR] [FLINK-40121][Connectors/Kafka] Build and test against Flink 2.3 [flink-connector-kafka] via GitHub
• 2026/10/23 Re: [PR] [FLINK-41066][table] Handle upsert inputs in multi-way joins [flink] via GitHub
• 2026/10/23 Re: [PR] [FLINK-41079][runtime-web] Update Angular to v22 and ng-zorro-antd to v22 [flink] via GitHub
• 2026/10/23 [jira] [Updated] (FLINK-41066) MultiJoin produces wrong results when an upsert input replaces a record without UPDATE_BEFORE ASF GitHub Bot (Jira)
• 2026/10/23 Re: [PR] [hotfix] Update copyright year to 2026 [flink-connector-cassandra] via GitHub
• 2026/10/23 Re: [PR] [hotfix] Update copyright year to 2026 [flink-connector-cassandra] via GitHub
• 2026/10/23 [PR] [hotfix] Update copyright year to 2026 [flink-connector-cassandra] via GitHub
• 2026/10/23 [jira] [Commented] (FLINK-41102) Keyed state clear operations are lost on key changes when python.state.cache-size is zero Sangkyoon Nam (Jira)
• 2026/10/23 [jira] [Commented] (FLINK-40123) heck_logs_for_exceptions false-positives on S3A stream_write_exceptions counter, flaking test_kubernetes_materialized_table.sh Martijn Visser (Jira)
• 2026/10/23 Re: [PR] [FLINK-24908][sql-client] Print the outermost exception that ends with the root cause [flink] via GitHub
• 2026/10/23 [jira] [Commented] (FLINK-41104) MapState.contains() returns false for an existing key whose value is None Sangkyoon Nam (Jira)
• 2026/10/23 [jira] [Commented] (FLINK-41106) MapState.put_all() iterates dictionary keys instead of key-value pairs Sangkyoon Nam (Jira)
• 2026/10/23 Re: [PR] [FLINK-41113][Build] Bump jackson, log4j, assertj and pin curator-test transitives [flink-connector-pulsar] via GitHub
• 2026/10/23 Re: [PR] [FLINK-24908][sql-client] Print the outermost exception that ends with the root cause [flink] via GitHub
• 2026/10/23 Re: [PR] [FLINK-24908][sql-client] Print the outermost exception that ends with the root cause [flink] via GitHub
• 2026/10/23 [jira] [Created] (FLINK-41109) Add guidelines for embedding user input in generated code to the planner's AGENTS.md Gustavo de Morais (Jira)
• 2026/10/23 [jira] [Assigned] (FLINK-41110) Find VARIANT object fields by comparing UTF-8 bytes Ramin Gharib (Jira)
• 2026/10/23 Re: [PR] [FLINK-41114][docs] Document uid argument for FROM_CHANGELOG and TO_CHANGELOG [flink] via GitHub
• 2026/10/23 [jira] [Commented] (FLINK-34468) Implement Lineage Interface in Cassandra Connector Peter Huang (Jira)
• 2026/10/23 [jira] [Updated] (FLINK-41114) Document the uid argument for FROM_CHANGELOG and TO_CHANGELOG ASF GitHub Bot (Jira)
• 2026/10/23 [PR] [FLINK-41114][docs] Document uid argument for FROM_CHANGELOG and TO_CHANGELOG [flink] via GitHub
• 2026/10/23 [jira] [Assigned] (FLINK-39049) Introduce built-in functions `VARIANT_GET` and `TRY_VARIANT_GET ` to extract values from a variant Ramin Gharib (Jira)
• 2026/10/23 [jira] [Created] (FLINK-41114) Document the uid argument for FROM_CHANGELOG and TO_CHANGELOG Gustavo de Morais (Jira)
• 2026/10/23 Re: [PR] [FLINK-41067][table] Don't store rows whose join key can never match in window and interval joins [flink] via GitHub
• 2026/10/23 Re: [PR] [FLINK-41067][table] Don't store rows whose join key can never match in window and interval joins [flink] via GitHub
• 2026/10/23 [jira] [Commented] (FLINK-41089) Make cleanup of docker image parallel Sergey Nuyanzin (Jira)
• 2026/10/23 [jira] [Resolved] (FLINK-41089) Make cleanup of docker image parallel Sergey Nuyanzin (Jira)
• 2026/10/23 Re: [PR] [FLINK-41089][ci] Make cleanup of docker image in parallel [flink] via GitHub
• 2026/10/23 [jira] [Commented] (FLINK-41109) Add guidelines for embedding user input in generated code to the planner's AGENTS.md Gustavo de Morais (Jira)
• 2026/10/23 [PR] [FLINK-41113][Build] Bump jackson, log4j, assertj and pin curator-test transitives [flink-connector-pulsar] via GitHub
• 2026/10/23 Re: [PR] [FLINK-41109][table] Add guidelines for query-controlled strings in generated code to planner AGENTS.md [flink] via GitHub
• 2026/10/23 [jira] [Resolved] (FLINK-41109) Add guidelines for embedding user input in generated code to the planner's AGENTS.md Gustavo de Morais (Jira)
• 2026/10/23 Re: [PR] [BP-2.2][FLINK-40904][FLINK-40780][runtime] Detect FORWARD parallelism mismatch correctly and make the downgrade configurable [flink] via GitHub
• 2026/10/23 Re: [PR] [FLINK-41113][Build] Bump jackson, log4j, assertj and pin curator-test transitives [flink-connector-pulsar] via GitHub
• 2026/10/23 [jira] [Updated] (FLINK-41113) Connectors/Pulsar: Bump dependency versions with known advisories in the root pom ASF GitHub Bot (Jira)
• 2026/10/23 [jira] [Commented] (FLINK-38783) Hybrid shuffle: ConcurrentModificationException in TieredStorageResourceRegistry during concurrent result partition creation abjfh (Jira)
• 2026/10/23 Re: [PR] [BP-1.20][FLINK-40904][FLINK-40780][runtime] Detect FORWARD parallelism mismatch correctly and make the downgrade configurable [flink] via GitHub
• 2026/10/23 Re: [PR] [FLINK-40121][Connectors/Kafka] Build and test against Flink 2.3 [flink-connector-kafka] via GitHub
• 2026/10/23 Re: [PR] [FLINK-40695] Add a retry state for failed ExecutionGraph creation [flink] via GitHub
• 2026/10/23 [jira] [Updated] (FLINK-41112) Support Flink 1.20 in the Cassandra connector ASF GitHub Bot (Jira)
• 2026/10/23 Re: [PR] [FLINK-38783][runtime] Make TieredStorageResourceRegistry thread-safe [flink] via GitHub
• 2026/10/23 [PR] [FLINK-41112][Connectors/Cassandra] Support Flink 1.20 [flink-connector-cassandra] via GitHub
• 2026/10/23 Re: [PR] [FLINK-38783][runtime] Make TieredStorageResourceRegistry thread-safe [flink] via GitHub
• 2026/10/23 Re: [PR] [FLINK-35376][runtime] Avoid duplicate PackagedProgram in REST JAR handlers [flink] via GitHub
• 2026/10/23 Re: [PR] [FLINK-41065][table] Allow process table functions to exclude state entries per call [flink] via GitHub
• 2026/10/23 [jira] [Commented] (FLINK-40873) Fix overlapping config key prefixes in the operator yongfu.gao (Jira)
• 2026/10/23 Re: [PR] [FLINK-41067][table] Don't store rows whose join key can never match in window and interval joins [flink] via GitHub
• 2026/10/23 Re: [PR] [FLINK-38783][runtime] Make TieredStorageResourceRegistry thread-safe [flink] via GitHub
• 2026/10/23 Re: [PR] [FLINK-38783][runtime] Make TieredStorageResourceRegistry thread-safe [flink] via GitHub
• 2026/10/23 Re: [PR] [FLINK-38413] Adding support for append only tables to MySQL Pipeline connector [flink-cdc] via GitHub
• 2026/10/23 Re: [PR] [FLINK-40936][table] Reject VARIANT elements and keys in functions that compare them [flink] via GitHub
• 2026/10/23 [jira] [Created] (FLINK-41113) Connectors/Pulsar: Bump dependency versions with known advisories in the root pom Purushottam Sinha (Jira)
• 2026/10/23 Re: [PR] [FLINK-41065][table] Allow process table functions to exclude state entries per call [flink] via GitHub
• 2026/10/23 Re: [PR] [FLINK-41076] Bump netty-tcnative to 2.0.84.Final (release-21.0) [flink-shaded] via GitHub
• 2026/10/23 Re: [PR] [FLINK-40936][table] Reject VARIANT elements and keys in functions that compare them [flink] via GitHub
• 2026/10/23 Re: [PR] [FLINK-40779][connector-jdbc] Snapshot splitter state together with its splits [flink-connector-jdbc] via GitHub
• 2026/10/23 Re: [PR] [FLINK-24908][sql-client] Print the outermost exception that ends with the root cause [flink] via GitHub
• 2026/10/23 [jira] [Created] (FLINK-41111) Changelog mode errors of FlinkChangelogModeInferenceProgram do not identify the part of the query that produces the changes Moritz Manner (Jira)
• 2026/10/23 Re: [PR] [FLINK-34625][python] Fix state TTL read cache disabling [flink] via GitHub
• 2026/10/23 Re: [PR] docs: remove stray brace in README streaming example [flink] via GitHub
• 2026/10/23 Re: [PR] [FLINK-24908][sql-client] Print the outermost exception that ends with the root cause [flink] via GitHub
• 2026/10/23 Re: [PR] [BP-3.7][hotfix][ci] Pin all runner images at Ubuntu 24.04 (#4594) [flink-cdc] via GitHub
• 2026/10/23 Re: [PR] [FLINK-41028] Support data lake table properties in the Fluss pipeline sink [flink-cdc] via GitHub
• 2026/10/23 [PR] docs: remove stray brace in README streaming example [flink] via GitHub
• 2026/10/23 Re: [PR] [hotfix][ci] Remove disallowed markdown link check action from docs workflow for release-3.7 [flink-cdc] via GitHub
• 2026/10/23 Re: [PR] [FLINK-41068][table] Don't store build rows whose join key can never match in LATERAL SNAPSHOT joins [flink] via GitHub
• 2026/10/23 Re: [PR] [FLINK-40936][table] Reject VARIANT elements and keys in functions that compare them [flink] via GitHub
• 2026/10/23 [jira] [Assigned] (FLINK-41111) Changelog mode errors of FlinkChangelogModeInferenceProgram do not identify the part of the query that produces the changes Gustavo de Morais (Jira)
• 2026/10/23 [jira] [Created] (FLINK-41108) PyFlink namespace merges leave stale cached values for TTL-enabled ListState Dian Fu (Jira)
• 2026/10/23 [jira] [Updated] (FLINK-41109) Add guidelines for embedding user input in generated code to the planner's AGENTS.md ASF GitHub Bot (Jira)
• 2026/10/23 Re: [PR] [BP-2.3][FLINK-40904][FLINK-40780][runtime] Detect FORWARD parallelism mismatch correctly and make the downgrade configurable [flink] via GitHub
• 2026/10/23 Re: [I] [Feature] Add LiteLLM Router SDK integration for model routing and failover [flink-agents] via GitHub
• 2026/10/23 [jira] [Resolved] (FLINK-41070) Cassandra connector CI fails downloading the Flink 1.19.0 binary Martijn Visser (Jira)
• 2026/10/23 Re: [PR] [FLINK-41065][table] Allow process table functions to exclude state entries per call [flink] via GitHub
• 2026/10/23 [jira] [Assigned] (FLINK-41086) JSON_LENGTH and JSON_TYPE fail the job when a JSON path function throws Ramin Gharib (Jira)
• 2026/10/23 [jira] [Comment Edited] (FLINK-39140) [FLINK-39140][checkpoint] Allow multiple rescales in Unaligned Checkpoint ITCases to perform checkpointing during recovery Martijn Visser (Jira)

• Earlier messages
• Later messages