issues  

Messages by Date

• 2026/09/18 Re: [PR] [FLINK-40707][python] Fix Beam imports in DefaultJobBundleFactoryTest [flink] via GitHub
• 2026/09/18 Re: [PR] [FLINK-35459] Use Incremental Source Framework in Flink tidb CDC Source Connector [flink-cdc] via GitHub
• 2026/09/18 [jira] [Updated] (FLINK-40664) JobIDLoggingITCase.testJobIDLogging fails on a "Freeing inactive slots" log line without the job id ASF GitHub Bot (Jira)
• 2026/09/18 [jira] [Updated] (FLINK-39600) FLIP-568: Strict BYTES-to-STRING CAST with UTF-8 Validation Utilities Gustavo de Morais (Jira)
• 2026/09/18 Re: [PR] [FLINK-28839][docs] Fix duplicate word in DataSet iterations example [flink] via GitHub
• 2026/09/18 Re: [PR] [FLINK-39712] Avoid duplicate bounded-source completion notifications [flink-connector-kafka] via GitHub
• 2026/09/18 [jira] [Commented] (FLINK-39600) FLIP-568: Strict BYTES-to-STRING CAST with UTF-8 Validation Utilities Gustavo de Morais (Jira)
• 2026/09/18 Re: [PR] [FLINK-34415] Move away from Kafka-Zookeeper based tests in favor of Kafka-KRaft [flink] via GitHub
• 2026/09/18 Re: [PR] Add Flink Community Update for Q2 2026 [flink-web] via GitHub
• 2026/09/18 Re: [PR] [FLINK-6417][connector/filesystem] Add opt-in glob enumeration for FileSource [flink] via GitHub
• 2026/09/18 [jira] [Resolved] (FLINK-40668) Document why the recovery drain cannot stall on zero-credit needsRecovery channels Rui Fan (Jira)
• 2026/09/18 [jira] [Comment Edited] (FLINK-40664) JobIDLoggingITCase.testJobIDLogging fails on a "Freeing inactive slots" log line without the job id Purushottam Sinha (Jira)
• 2026/09/18 Re: [PR] [FLINK-40450][table-planner] Add missing flink-table-code-splitter test dependency [flink] via GitHub
• 2026/09/18 [jira] [Updated] (FLINK-40450) Planner tests miss direct flink-table-code-splitter test dependency ASF GitHub Bot (Jira)
• 2026/09/18 Re: [PR] [FLINK-40472][python] Support Arrow vectorized UDFs in DataFrame API [flink] via GitHub
• 2026/09/18 Re: [PR] fix: chore(docker): migrate Kafka image from bitnami/kafka to bitnami… [flink-playgrounds] via GitHub
• 2026/09/18 Re: [PR] [FLINK-40707][python] Fix Beam imports in DefaultJobBundleFactoryTest [flink] via GitHub
• 2026/09/18 Re: [PR] [hotfix] [opensearch] Make branch compatible with Flink 1.19/1.20 [flink-connector-opensearch] via GitHub
• 2026/09/18 [jira] [Resolved] (FLINK-40707) Backports of FLINK-39572 breaks previous releases because of different Beam version Martijn Visser (Jira)
• 2026/09/18 Re: [PR] [FLINK-40707][python] Fix Beam imports in DefaultJobBundleFactoryTest [flink] via GitHub
• 2026/09/18 [jira] [Created] (FLINK-40708) Support ValueView in PTFs Timo Walther (Jira)
• 2026/09/18 Re: [PR] [FLINK-6417][connector/filesystem] Add opt-in glob enumeration for FileSource [flink] via GitHub
• 2026/09/18 [jira] [Updated] (FLINK-40707) Backports of FLINK-39572 breaks previous releases because of different Beam version ASF GitHub Bot (Jira)
• 2026/09/18 Re: [PR] [FLINK-40664][tests] Ignore Freeing inactive slots log in JobIDLoggingITCase [flink] via GitHub
• 2026/09/18 Re: [PR] Add Flink Community Update for Q2 2026 [flink-web] via GitHub
• 2026/09/18 Re: [PR] [FLINK-40148][common] Fix TableIdRouter producing wrong sink table for multi-digit source suffix [flink-cdc] via GitHub
• 2026/09/18 [PR] [api][java] Validate retry parameters in RetryExecutor builder [flink-agents] via GitHub
• 2026/09/18 [jira] [Updated] (FLINK-39600) FLIP-568: Strict BYTES-to-STRING CAST with UTF-8 Validation Utilities Gustavo de Morais (Jira)
• 2026/09/18 [jira] [Commented] (FLINK-40704) Enable spotless for java25 Sergey Nuyanzin (Jira)
• 2026/09/18 [jira] [Commented] (FLINK-34415) Move away from Kafka-Zookeeper based tests in favor of Kafka-KRaft Martijn Visser (Jira)
• 2026/09/18 Re: [PR] [FLINK-34415] Move away from Kafka-Zookeeper based tests in favor of Kafka-KRaft [flink] via GitHub
• 2026/09/18 [jira] [Closed] (FLINK-34415) Move away from Kafka-Zookeeper based tests in favor of Kafka-KRaft Martijn Visser (Jira)
• 2026/09/18 Re: [PR] [FLINK-40595][s3] Preserve multipart uploads during recoverable stream disposal [flink] via GitHub
• 2026/09/18 [jira] [Updated] (FLINK-40707) Backports of FLINK-39572 breaks previous releases because of different Beam version Martijn Visser (Jira)
• 2026/09/18 Re: [PR] [FLINK-40707][python] Fix Beam imports in DefaultJobBundleFactoryTest [flink] via GitHub
• 2026/09/18 Re: [PR] [FLINK-39115][s3] Support URI Handling Utility [flink] via GitHub
• 2026/09/18 Re: [PR] fix: chore(docker): migrate Kafka image from bitnami/kafka to bitnami… [flink-playgrounds] via GitHub
• 2026/09/18 Re: [PR] [FLINK-40664][tests] Ignore Freeing inactive slots log in JobIDLoggingITCase [flink] via GitHub
• 2026/09/18 [PR] [FLINK-40707][python] Fix Beam imports in DefaultJobBundleFactoryTest [flink] via GitHub
• 2026/09/18 [PR] [FLINK-40707][python] Fix Beam imports in DefaultJobBundleFactoryTest [flink] via GitHub
• 2026/09/18 Re: [PR] [FLINK-40668][network] Document why the recovery drain cannot stall on zero-credit needsRecovery channels [flink] via GitHub
• 2026/09/18 Re: [PR] [FLINK-38551][table-planner] Extend MultiJoin tests based on current join tests [flink] via GitHub
• 2026/09/18 [jira] [Resolved] (FLINK-40704) Enable spotless for java25 Sergey Nuyanzin (Jira)
• 2026/09/18 Re: [PR] [FLINK-40704][build] Enable spotless for java 25 [flink] via GitHub
• 2026/09/18 [jira] [Assigned] (FLINK-40664) JobIDLoggingITCase.testJobIDLogging fails on a "Freeing inactive slots" log line without the job id Martijn Visser (Jira)
• 2026/09/18 [jira] [Created] (FLINK-40707) Backports of FLINK-39572 breaks previous releases because of different Beam version Martijn Visser (Jira)
• 2026/09/18 Re: [PR] [api][runtime][java][python] Add composable durable futures [flink-agents] via GitHub
• 2026/09/18 [jira] [Assigned] (FLINK-40706) Harden address validation in kubernetes operator artifact fetcher for IPv6 Robert Metzger (Jira)
• 2026/09/18 Re: [PR] [FLINK-40595][s3] Preserve multipart uploads during recoverable stream disposal [flink] via GitHub
• 2026/09/18 [PR] [FLINK-28839][docs] Fix duplicate word in DataSet iterations example [flink] via GitHub
• 2026/09/18 [jira] [Updated] (FLINK-28839) Incorrect english sentence in docs/content/docs/dev/dataset/iterations.md ASF GitHub Bot (Jira)
• 2026/09/18 [PR] [FLINK-40664][tests] Ignore Freeing inactive slots log in JobIDLoggingITCase [flink] via GitHub
• 2026/09/18 Re: [I] [Tech Debt][API][Action] Improve annotation-based cross-language Action declarations [flink-agents] via GitHub
• 2026/09/18 Re: [PR] [FLINK-40696] Revert observed runtime config logic [flink-kubernetes-operator] via GitHub
• 2026/09/17 Re: [PR] [FLINK-38551][table-planner] Extend MultiJoin tests based on current join tests [flink] via GitHub
• 2026/09/17 Re: [PR] [FLINK-37351][runtime] Ensure Writer/Committer Colocation for Non-Pre-Commit Topologies [flink] via GitHub
• 2026/09/17 Re: [PR] [FLINK-34415] Move away from Kafka-Zookeeper based tests in favor of Kafka-KRaft [flink] via GitHub
• 2026/09/17 Re: [PR] [FLINK-39788][kubernetes] Append .svc suffix to namespaced Kubernetes service hostnames [flink] via GitHub
• 2026/09/17 Re: [PR] [FLINK-24544][formats] Fix Avro enum deserialization failure with Confluent Schema Registry [flink] via GitHub
• 2026/09/17 Re: [PR] [FLINK-39115][s3] Support URI Handling Utility [flink] via GitHub
• 2026/09/17 [jira] [Updated] (FLINK-40706) Harden address validation in kubernetes operator artifact fetcher for IPv6 Purushottam Sinha (Jira)
• 2026/09/17 [jira] [Updated] (FLINK-40706) Harden address validation in kubernetes operator artifact fetcher for IPv6 Purushottam Sinha (Jira)
• 2026/09/17 Re: [PR] [runtime][java][skills] Bound download and extraction size [flink-agents] via GitHub
• 2026/09/17 [jira] [Created] (FLINK-40706) Harden address validation in kubernetes operator artifact fetcher Purushottam Sinha (Jira)
• 2026/09/17 Re: [PR] [integrations][java] Add OpenAI embedding model [flink-agents] via GitHub
• 2026/09/17 [jira] (FLINK-40640) [Iceberg] UPDATE that changes a partitioned column's value leaves a duplicate stale row in the old partition Yanquan Lv (Jira)
• 2026/09/17 Re: [PR] [hotfix] Fix "doesn't exists" grammar typos [flink] via GitHub
• 2026/09/17 [PR] [hotfix] Bump checkout version to v7 in snapshots [flink-docker] via GitHub
• 2026/09/17 Re: [PR] [FLINK-37155][historyserver] Decouple remote archive retention from local processing limit [flink] via GitHub
• 2026/09/17 [jira] [Resolved] (FLINK-40640) [Iceberg] UPDATE that changes a partitioned column's value leaves a duplicate stale row in the old partition Yanquan Lv (Jira)
• 2026/09/17 Re: [PR] [FLINK-40704][build] Enable spotless for java 25 [flink] via GitHub
• 2026/09/17 [jira] [Updated] (FLINK-40696) Revert observed runtime config logic ASF GitHub Bot (Jira)
• 2026/09/17 [PR] [FLINK-40696] Revert observed runtime config logic [flink-kubernetes-operator] via GitHub
• 2026/09/17 [jira] [Assigned] (FLINK-40705) PyFlink pandas UDFs fail on MAP inputs across Arrow batches Dian Fu (Jira)
• 2026/09/17 Re: [PR] [FLINK-40647][runtime] Support best-effort schema expansion for existing sink tables during table creation [flink-cdc] via GitHub
• 2026/09/17 Re: [PR] [FLINK-40640][iceberg] Fix duplicate rows when an UPDATE changes the partition value [flink-cdc] via GitHub
• 2026/09/17 Re: [PR] [FLINK-40472][python] Support Arrow vectorized UDFs in DataFrame API [flink] via GitHub
• 2026/09/17 Re: [PR] [FLINK-40640][iceberg] Fix duplicate rows when an UPDATE changes the partition value [flink-cdc] via GitHub
• 2026/09/17 [jira] [Updated] (FLINK-39300) [flink-cdc] Reuse ObjectMapper as static constant to avoid repeated instantiation Ferenc Csaky (Jira)
• 2026/09/17 [jira] [Updated] (FLINK-40640) [Iceberg] UPDATE that changes a partitioned column's value leaves a duplicate stale row in the old partition Ferenc Csaky (Jira)
• 2026/09/17 [jira] [Assigned] (FLINK-40640) [Iceberg] UPDATE that changes a partitioned column's value leaves a duplicate stale row in the old partition Ferenc Csaky (Jira)
• 2026/09/17 [jira] [Commented] (FLINK-40640) [Iceberg] UPDATE that changes a partitioned column's value leaves a duplicate stale row in the old partition Ferenc Csaky (Jira)
• 2026/09/17 Re: [PR] [FLINK-40640][iceberg] Fix duplicate rows when an UPDATE changes the partition value [flink-cdc] via GitHub
• 2026/09/17 Re: [PR] [FLINK-40472][python] Support Arrow vectorized UDFs in DataFrame API [flink] via GitHub
• 2026/09/17 Re: [PR] [FLINK-40472][python] Support Arrow vectorized UDFs in DataFrame API [flink] via GitHub
• 2026/09/17 [jira] [Updated] (FLINK-40705) PyFlink pandas UDFs fail on MAP inputs across Arrow batches Liu Liu (Jira)
• 2026/09/17 [jira] [Updated] (FLINK-40705) PyFlink pandas UDFs fail on MAP inputs across Arrow batches Liu Liu (Jira)
• 2026/09/17 [jira] [Created] (FLINK-40705) PyFlink pandas UDFs fail on MAP inputs across Arrow batches Liu Liu (Jira)
• 2026/09/17 Re: [PR] Kubernetes Operator 1.16.1 release [flink-web] via GitHub
• 2026/09/17 Re: [PR] [integrations][java] Add OpenAI embedding model [flink-agents] via GitHub
• 2026/09/17 Re: [PR] [integrations][java] Add OpenAI embedding model [flink-agents] via GitHub
• 2026/09/17 Re: [PR] [FLINK-40434][python] Add flat_map support to the DataFrame API [flink] via GitHub
• 2026/09/17 Re: [PR] [FLINK-40704][build] Enable spotless for java 25 [flink] via GitHub
• 2026/09/17 [jira] [Updated] (FLINK-40434) Add flat_map support to DataFrame API ASF GitHub Bot (Jira)
• 2026/09/17 [PR] [FLINK-40434][python] Add flat_map support to the DataFrame API [flink] via GitHub
• 2026/09/17 Re: [PR] [FLINK-6417][connector/filesystem] Support glob paths in FileSource [flink] via GitHub
• 2026/09/17 Re: [PR] [docs] Add Model Routing user documentation [flink-agents] via GitHub
• 2026/09/17 Re: [PR] [FLINK-40472][python] Support Arrow vectorized UDFs in DataFrame API [flink] via GitHub
• 2026/09/17 Re: [I] [Bug][api] RetryExecutor accepts negative maxRetries and then fails with NullPointerException [flink-agents] via GitHub
• 2026/09/17 Re: [PR] [hotfix][api][java] Add tests for enum value parsers [flink-agents] via GitHub
• 2026/09/17 Re: [PR] [FLINK-40640][iceberg] Fix duplicate rows when an UPDATE changes the partition value [flink-cdc] via GitHub
• 2026/09/17 Re: [PR] [FLINK-40640][iceberg] Fix duplicate rows when an UPDATE changes the partition value [flink-cdc] via GitHub
• 2026/09/17 [jira] [Closed] (FLINK-39572) Hide sensitive information when pyflink's beam runner is closed Dian Fu (Jira)
• 2026/09/17 Re: [PR] [FLINK-39572][python] Do not log the Beam environment payload [flink] via GitHub
• 2026/09/17 [I] [Feature] Support cross-language subagent usage [flink-agents] via GitHub
• 2026/09/17 [I] [Feature] Support registering ReActAgent as a general-purpose subagent [flink-agents] via GitHub
• 2026/09/17 [PR] [api][plan][runtime][python] Support registering an Agent as an in-process internal sub-agent [flink-agents] via GitHub
• 2026/09/17 Re: [I] [Bug][plan] sub-agent cannot be rebuilt on a remote task after plan serialization [flink-agents] via GitHub
• 2026/09/17 [jira] [Commented] (FLINK-40697) Release finished snapshot split metadata in the incremental source framework (flink-cdc-base) Leonard Xu (Jira)
• 2026/09/17 [jira] [Assigned] (FLINK-40697) Release finished snapshot split metadata in the incremental source framework (flink-cdc-base) Leonard Xu (Jira)
• 2026/09/17 Re: [PR] [api][integrations][java][python] Ask each connection whether it could apply a schema natively [flink-agents] via GitHub
• 2026/09/17 Re: [PR] Bump soupsieve from 2.8.4 to 2.9 in /flink-python/docs [flink] via GitHub
• 2026/09/17 [I] [Feature] Support in-process internal sub-agent [flink-agents] via GitHub
• 2026/09/17 [PR] Bump soupsieve from 2.8.4 to 2.9 in /flink-python/docs [flink] via GitHub
• 2026/09/17 [PR] [hotfix] [opensearch] Make branch compatible with Flink 1.19/1.20 [flink-connector-opensearch] via GitHub
• 2026/09/17 [I] [Bug][api] RetryExecutor accepts negative maxRetries and then fails with NullPointerException [flink-agents] via GitHub
• 2026/09/17 [PR] [hotfix][api][java] Add tests for enum value parsers [flink-agents] via GitHub
• 2026/09/17 Re: [PR] [FLINK-40704][build] Enable spotless for java 25 [flink] via GitHub
• 2026/09/17 [jira] [Updated] (FLINK-40704) Enable spotless for java25 ASF GitHub Bot (Jira)
• 2026/09/17 [PR] [FLINK-40704][build] Enable spotless for java 25 [flink] via GitHub
• 2026/09/17 [jira] [Created] (FLINK-40704) Enable spotless for java25 Sergey Nuyanzin (Jira)
• 2026/09/17 Re: [PR] [FLINK-40701][build] Upgrade ArchUnit to 1.5.0 [flink] via GitHub
• 2026/09/17 [jira] [Commented] (FLINK-40588) DynamicKafkaSourceReaderTest.testNotifyNoMoreSplits is flaky Sylwester Lachiewicz (Jira)
• 2026/09/17 [jira] [Commented] (FLINK-40624) KafkaCommitter and ExactlyOnceKafkaWriter do not handle InvalidProducerEpochException alongside ProducerFencedException Sylwester Lachiewicz (Jira)
• 2026/09/17 [jira] [Updated] (FLINK-40703) Improve correctness coverage: Add ITCase for recovery from a checkpoint whose pooled transactional id was reused by a later checkpoint ASF GitHub Bot (Jira)
• 2026/09/17 [PR] [FLINK-40703][tests] Cover KafkaSink recovery after pooled transaction ID reuse [flink-connector-kafka] via GitHub
• 2026/09/17 [jira] [Assigned] (FLINK-40703) Improve correctness coverage: Add ITCase for recovery from a checkpoint whose pooled transactional id was reused by a later checkpoint Jim Hughes (Jira)
• 2026/09/17 Re: [PR] [hotfix] Bump actions to avoid warnings in GHA output [flink-connector-shared-utils] via GitHub
• 2026/09/17 [jira] [Created] (FLINK-40703) Improve correctness coverage: Add ITCase for recovery from a checkpoint whose pooled transactional id was reused by a later checkpoint Aleksandr Savonin (Jira)
• 2026/09/17 Re: [PR] [FLINK-40136][Connectors/Kafka] Fix flaky ConcurrentModificationException in DynamicKafkaSourceEnumeratorTest [flink-connector-kafka] via GitHub
• 2026/09/17 Re: [PR] [FLINK-40615][Connectors/Kafka] Fix duplicate partition assignment in KafkaSourceEnumerator [flink-connector-kafka] via GitHub
• 2026/09/17 Re: [PR] [FLINK-40136][Connectors/Kafka] Fix flaky ConcurrentModificationException in DynamicKafkaSourceEnumeratorTest [flink-connector-kafka] via GitHub
• 2026/09/17 Re: [PR] [hotfix] [opensearch] Use supported Flink versions in .github/workflows/weekly.yml [flink-connector-opensearch] via GitHub
• 2026/09/17 [PR] [hotfix] Bump actions to avoid warnings in GHA output [flink-connector-shared-utils] via GitHub
• 2026/09/17 [PR] [hotfix] [opensearch] Use supported Flink versions in .github/workflows/weekly.yml [flink-connector-opensearch] via GitHub
• 2026/09/17 Re: [PR] [FLINK-40701][build] Upgrade ArchUnit to 1.5.0 [flink] via GitHub
• 2026/09/17 Re: [PR] [FLINK-34251][core] Improve diagnostics for closure serialization failures [flink] via GitHub
• 2026/09/17 [jira] [Updated] (FLINK-40701) Upgrade ArchUnit to 1.5.0 ASF GitHub Bot (Jira)
• 2026/09/17 Re: [PR] Bump org.apache.logging.log4j:log4j-core from 2.24.1 to 2.25.4 [flink-connector-opensearch] via GitHub
• 2026/09/17 Re: [PR] Bump org.apache.logging.log4j:log4j-core from 2.24.1 to 2.25.4 [flink-connector-opensearch] via GitHub
• 2026/09/17 Re: [PR] Bump org.apache.logging.log4j:log4j-core from 2.24.1 to 2.25.4 [flink-connector-opensearch] via GitHub
• 2026/09/17 [PR] [FLINK-40701][build] Upgrade ArchUnit to 1.5.0 [flink] via GitHub
• 2026/09/17 Re: [PR] Bump org.apache.logging.log4j:log4j-1.2-api from 2.24.1 to 2.25.4 [flink-connector-opensearch] via GitHub
• 2026/09/17 Re: [PR] Bump org.apache.logging.log4j:log4j-1.2-api from 2.24.1 to 2.25.4 [flink-connector-opensearch] via GitHub
• 2026/09/17 Re: [PR] Bump org.apache.logging.log4j:log4j-1.2-api from 2.24.1 to 2.25.4 [flink-connector-opensearch] via GitHub
• 2026/09/17 [PR] [FLINK-34251][core] Improve diagnostics for closure serialization failures [flink] via GitHub
• 2026/09/17 Re: [PR] Bump org.apache.logging.log4j:log4j-core from 2.24.1 to 2.25.4 [flink-connector-opensearch] via GitHub
• 2026/09/17 Re: [PR] [hotfix][opensearch3] Converge HttpClient 5.6.3 dependency [flink-connector-opensearch] via GitHub
• 2026/09/17 Re: [PR] Bump org.apache.logging.log4j:log4j-1.2-api from 2.24.1 to 2.25.4 [flink-connector-opensearch] via GitHub
• 2026/09/17 Re: [PR] Bump org.apache.httpcomponents.client5:httpclient5 from 5.6 to 5.6.3 in /flink-connector-opensearch3 [flink-connector-opensearch] via GitHub
• 2026/09/17 Re: [PR] Bump org.apache.logging.log4j:log4j-1.2-api from 2.24.1 to 2.25.4 [flink-connector-opensearch] via GitHub
• 2026/09/17 Re: [PR] Bump org.apache.httpcomponents.client5:httpclient5 from 5.6 to 5.6.3 in /flink-connector-opensearch3 [flink-connector-opensearch] via GitHub
• 2026/09/17 Re: [PR] Bump org.apache.httpcomponents.client5:httpclient5 from 5.6 to 5.6.3 in /flink-connector-opensearch3 [flink-connector-opensearch] via GitHub
• 2026/09/17 Re: [PR] Bump org.apache.logging.log4j:log4j-1.2-api from 2.24.1 to 2.25.4 [flink-connector-opensearch] via GitHub
• 2026/09/17 Re: [PR] [hotfix][opensearch3] Converge HttpClient 5.6.3 dependency [flink-connector-opensearch] via GitHub
• 2026/09/17 Re: [PR] Bump org.apache.httpcomponents.client5:httpclient5 from 5.6 to 5.6.3 in /flink-connector-opensearch3 [flink-connector-opensearch] via GitHub
• 2026/09/17 [jira] [Commented] (FLINK-40697) Release finished snapshot split metadata in the incremental source framework (flink-cdc-base) Spoorthi Basu (Jira)
• 2026/09/17 [jira] [Resolved] (FLINK-40667) Buffer ref-count leaks in CDR recovery filtering end in free() on a live segment Rui Fan (Jira)
• 2026/09/17 [jira] [Created] (FLINK-40695) Transient issues during ExecutionGraph creation lead to terminal job Failure Ahmed Hamdy (Jira)
• 2026/09/17 Re: [PR] [FLINK-40698][build] Bump japicmp-maven-plugin to 0.26.2 [flink] via GitHub
• 2026/09/17 Re: [PR] [FLINK-40617][build] Prune and bump dependency versions in the root pom [flink-connector-kafka] via GitHub
• 2026/09/17 [jira] [Updated] (FLINK-40697) Release finished snapshot split metadata in the incremental source framework (flink-cdc-base) ASF GitHub Bot (Jira)
• 2026/09/17 [PR] [FLINK-40697][cdc-base] Release finished snapshot split metadata after entering the stream phase [flink-cdc] via GitHub
• 2026/09/17 [jira] [Updated] (FLINK-40617) Connectors/Kafka: Prune and bump dependency versions in the root pom Purushottam Sinha (Jira)
• 2026/09/17 [jira] [Created] (FLINK-40694) INSERT INTO with a column list fails over a process table function with a set-semantic table argument Martijn Visser (Jira)
• 2026/09/17 [jira] [Updated] (FLINK-40662) 'Run kubernetes Materialized Table test' fails because the SQL Gateway returns a null session handle Martijn Visser (Jira)
• 2026/09/17 Re: [PR] [FLINK-40277][connector-http] Add HTTP sink status-code handling and retries [flink-connector-http] via GitHub
• 2026/09/17 [jira] [Created] (FLINK-40702) Unify shared HTTP sink and lookup configuration options Bharath Reddy Gunapati (Jira)
• 2026/09/17 [jira] [Updated] (FLINK-40698) Bump japicmp-maven-plugin to 0.26.2 ASF GitHub Bot (Jira)
• 2026/09/17 [PR] [FLINK-40698][build] Bump japicmp-maven-plugin to 0.26.2 [flink] via GitHub
• 2026/09/17 [jira] [Created] (FLINK-40701) Upgrade ArchUnit to 1.5.0 Martijn Visser (Jira)
• 2026/09/17 [jira] [Commented] (FLINK-40467) Flink 2.3 Application Mode managed by the kubernetes operator can start without submitting the new job after savepoint redeploy Gyula Fora (Jira)
• 2026/09/17 [jira] [Updated] (FLINK-40467) Flink 2.3 Application Mode managed by the kubernetes operator can start without submitting the new job after savepoint redeploy Gyula Fora (Jira)
• 2026/09/17 Re: [PR] [FLINK-40277][connector-http] Add HTTP sink status-code handling and retries [flink-connector-http] via GitHub
• 2026/09/17 [jira] [Created] (FLINK-40700) Add typed DataStream configuration for HTTP sink options Bharath Reddy Gunapati (Jira)
• 2026/09/17 Re: [PR] [FLINK-40277][connector-http] Add HTTP sink status-code handling and retries [flink-connector-http] via GitHub
• 2026/09/17 Re: [PR] [FLINK-40148][common] Fix TableIdRouter producing wrong sink table for multi-digit source suffix [flink-cdc] via GitHub
• 2026/09/17 Re: [PR] [FLINK-40277][connector-http] Add HTTP sink status-code handling and retries [flink-connector-http] via GitHub
• 2026/09/17 Re: [PR] [FLINK-39416] Fix link address errors in documents [flink-cdc] via GitHub
• 2026/09/17 [jira] [Created] (FLINK-40699) Add HTTP sink continue-on-error and optional error/DLQ handling Bharath Reddy Gunapati (Jira)
• 2026/09/17 [jira] [Created] (FLINK-40696) Revert observed runtime config logic Gyula Fora (Jira)
• 2026/09/17 Re: [PR] [FLINK-39410] The `flink-cdc-pipeline-connector-elasticsearch` module offers better compatibility with Flink 1.20 and Flink 2.x [flink-cdc] via GitHub
• 2026/09/17 [jira] [Created] (FLINK-40698) Bump japicmp-maven-plugin to 0.26.2 Martijn Visser (Jira)
• 2026/09/17 Re: [PR] [FLINK-40277][connector-http] Add HTTP sink status-code handling and retries [flink-connector-http] via GitHub
• 2026/09/17 Re: [PR] [FLINK-39386] For Flink 2.x+, support limit the rate at the source [flink-cdc] via GitHub
• 2026/09/17 Re: [PR] [FLINK-40277][connector-http] Add HTTP sink status-code handling and retries [flink-connector-http] via GitHub
• 2026/09/17 Re: [PR] [Feature][Java] Move MCP resource discovery to runtime [flink-agents] via GitHub
• 2026/09/17 Re: [PR] [Feature][Java] Move MCP resource discovery to runtime [flink-agents] via GitHub
• 2026/09/17 Re: [PR] [FLINK-40685][state/forst] Reclaim cached files after checkpoint ownership handoff [flink] via GitHub
• 2026/09/17 Re: [PR] [docs] Add Model Routing user documentation [flink-agents] via GitHub
• 2026/09/17 Re: [PR] [FLINK-40687][build] Relocate the packages the model uber jars actually bundle [flink] via GitHub
• 2026/09/17 [jira] [Commented] (FLINK-40587) Recreating a FlinkDeployment throws an autoscaler exception Gyula Fora (Jira)
• 2026/09/17 [jira] [Created] (FLINK-40697) Release finished snapshot split metadata in the incremental source framework (flink-cdc-base) Spoorthi Basu (Jira)
• 2026/09/17 Re: [PR] [FLINK-29549]- Flink Glue Catalog integration [flink-connector-aws] via GitHub
• 2026/09/17 Re: [PR] [FLINK-29549]- Flink Glue Catalog integration [flink-connector-aws] via GitHub
• 2026/09/17 [I] [Umbrella][Feature] Subagent Resource [flink-agents] via GitHub
• 2026/09/17 [PR] Kubernetes Operator 1.16.1 release [flink-web] via GitHub
• 2026/09/17 [jira] [Updated] (FLINK-40587) Recreating a FlinkDeployment throws an autoscaler exception Gyula Fora (Jira)
• 2026/09/17 [jira] [Updated] (FLINK-40685) ForSt skips local cache cleanup for checkpoint-owned files ASF GitHub Bot (Jira)
• 2026/09/17 [PR] [FLINK-40685][state/forst] Reclaim cached files after checkpoint ownership handoff [flink] via GitHub

• Earlier messages
• Later messages