issues  

Messages by Date

• 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
• 2026/09/17 [I] Add a @ModelRouterSetup annotation for declaring model routers inside an agent class [flink-agents] via GitHub
• 2026/09/17 Re: [PR] [FLINK-40662][tests] Fail fast when the S3 test container does not start [flink] via GitHub
• 2026/09/17 [jira] [Updated] (FLINK-40687) flink-model shade relocations do not match, okhttp and kotlin ship unrelocated ASF GitHub Bot (Jira)
• 2026/09/17 [PR] [FLINK-40687][build] Relocate the packages the model uber jars actually bundle [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] [Assigned] (FLINK-40504) FLIP-27 source never re-emits WatermarkStatus.ACTIVE after idleness unless its watermark strictly advances Martijn Visser (Jira)
• 2026/09/17 Re: [PR] [FLINK-40694][table-planner] Fix INSERT INTO with a column list over set-semantic PTFs [flink] via GitHub
• 2026/09/17 Re: [PR] Port commits for 1.16.1 [flink-kubernetes-operator] via GitHub
• 2026/09/17 [jira] [Updated] (FLINK-40694) INSERT INTO with a column list fails over a process table function with a set-semantic table argument ASF GitHub Bot (Jira)
• 2026/09/17 [PR] [FLINK-40694][table-planner] Fix INSERT INTO with a column list over set-semantic PTFs [flink] via GitHub
• 2026/09/17 [jira] [Reopened] (FLINK-35746) Add logic to override observed config based on settings observed through REST API Gyula Fora (Jira)
• 2026/09/17 [jira] [Commented] (FLINK-40632) Remove Experimental Annotation of Native S3 Samrat Deb (Jira)
• 2026/09/17 [jira] [Closed] (FLINK-40632) Remove Experimental Annotation of Native S3 Samrat Deb (Jira)
• 2026/09/17 Re: [PR] [FLINK-40632][s3] Annotate native-s3-fs to PublicEvolving [flink] via GitHub
• 2026/09/17 Re: [PR] [api][plan][python] Expose sub-agents to chat models as callable tools [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 Re: [PR] [api][integrations][java][python] Ask each connection whether it could apply a schema natively [flink-agents] via GitHub
• 2026/09/17 [PR] Port commits for 1.16.1 [flink-kubernetes-operator] via GitHub
• 2026/09/17 Re: [PR] [api][plan][python] Expose sub-agents to chat models as callable tools [flink-agents] via GitHub
• 2026/09/17 Re: [PR] [FLINK-40568][tests] Fix flaky ProcessTableFunctionSemanticTests by using materialized data assertion [flink] via GitHub
• 2026/09/17 [jira] [Commented] (FLINK-39600) FLIP-568: Strict BYTES-to-STRING CAST with UTF-8 Validation Utilities Sumin Joo (Jira)
• 2026/09/17 Re: [PR] [FLINK-40576][fs] Drop stale dependencies from flink-s3-fs-presto NOTICE [flink] via GitHub
• 2026/09/17 Re: [PR] [api][plan][python] Expose sub-agents to chat models as callable tools [flink-agents] via GitHub
• 2026/09/17 Re: [PR] [FLINK-40667][network] Fix buffer ref-count leak in recovery channel-state filtering [flink] via GitHub
• 2026/09/17 Re: [PR] [api][plan][python] Expose sub-agents to chat models as callable tools [flink-agents] via GitHub
• 2026/09/17 Re: [PR] [api][plan][python] Expose sub-agents to chat models as callable tools [flink-agents] via GitHub
• 2026/09/17 Re: [PR] [api][plan][python] Expose sub-agents to chat models as callable tools [flink-agents] via GitHub
• 2026/09/17 Re: [PR] [FLINK-40692][model] Make model-version optional in Triton inference URL [flink] via GitHub
• 2026/09/17 Re: [PR] [FLINK-39572][python] Do not log the Beam environment payload [flink] via GitHub
• 2026/09/17 [PR] [FLINK-39572][python] Do not log the Beam environment payload [flink] via GitHub
• 2026/09/17 [jira] [Assigned] (FLINK-39572) Hide sensitive information when pyflink's beam runner is closed Martijn Visser (Jira)
• 2026/09/17 [jira] [Resolved] (FLINK-40070) DynamicParameterITCase hangs when the JobManager startup banner rolls to a numbered log file Martijn Visser (Jira)
• 2026/09/17 [jira] [Commented] (FLINK-40070) DynamicParameterITCase hangs when the JobManager startup banner rolls to a numbered log file Martijn Visser (Jira)
• 2026/09/17 [jira] [Closed] (FLINK-40669) Java 11 E2E group 2 on release-2.3 is killed at the 234 minute budget while the other profiles finish in half the time Martijn Visser (Jira)
• 2026/09/17 Re: [PR] [BP-2.2][FLINK-40070][tests] Fix flaky DynamicParameterITCase reading rolled JobManager logs [flink] via GitHub
• 2026/09/17 [jira] [Updated] (FLINK-40070) DynamicParameterITCase hangs when the JobManager startup banner rolls to a numbered log file Martijn Visser (Jira)
• 2026/09/17 Re: [PR] [BP-2.3][FLINK-40070][tests] Fix flaky DynamicParameterITCase reading rolled JobManager logs [flink] via GitHub
• 2026/09/17 Re: [PR] [BP-1.20][FLINK-40070][tests] Fix flaky DynamicParameterITCase reading rolled JobManager logs [flink] via GitHub
• 2026/09/17 Re: [PR] [FLINK-38727][tests] Remove checkpointing test startup delay [flink] via GitHub
• 2026/09/17 [PR] [FLINK-38727][tests] Remove checkpointing test startup delay [flink] via GitHub
• 2026/09/17 Re: [PR] [FLINK-40692][model] Make model-version optional in Triton inference URL [flink] via GitHub
• 2026/09/17 [jira] [Updated] (FLINK-40692) [Model] Use default model version from server when no version is defined in model config ASF GitHub Bot (Jira)
• 2026/09/17 [PR] [FLINK-40692][model] Make model-version optional in Triton inference URL [flink] via GitHub
• 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-38727][test] Fix flaky test EventTimeWindowCheckpointingITCase#testPreAggregatedSlidingTimeWindow by increasing ResourceManagerOptions.REQUIREMENTS_CHECK_DELAY [flink] via GitHub
• 2026/09/17 Re: [PR] [FLINK-40662][tests] Fail fast when the S3 test container does not start [flink] via GitHub
• 2026/09/17 [jira] [Assigned] (FLINK-40662) 'Run kubernetes Materialized Table test' fails because the SQL Gateway returns a null session handle 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 ASF GitHub Bot (Jira)
• 2026/09/17 [PR] [FLINK-40662][tests] Fail fast when the S3 test container does not start [flink] via GitHub
• 2026/09/17 Re: [PR] [FLINK-40671][network] Document why UnknownInputChannel graduation hardcodes needsRecovery=false [flink] via GitHub
• 2026/09/17 Re: [PR] [FLINK-40667][network] Fix buffer ref-count leak in recovery channel-state filtering [flink] via GitHub
• 2026/09/17 Re: [PR] [integrations][java] Add OpenAI embedding model [flink-agents] via GitHub
• 2026/09/17 Re: [PR] [FLINK-40693][table] Align floating-point IN predicates with equality for signed zero [flink] via GitHub
• 2026/09/17 Re: [PR] [FLINK-40667][network] Fix buffer ref-count leak in recovery channel-state filtering [flink] via GitHub
• 2026/09/17 Re: [PR] [FLINK-40667][network] Fix buffer ref-count leak in recovery channel-state filtering [flink] via GitHub
• 2026/09/17 [jira] [Updated] (FLINK-40693) FLOAT/DOUBLE IN and NOT IN disagree with equality for signed zero ASF GitHub Bot (Jira)
• 2026/09/17 [PR] [FLINK-40693][table] Align floating-point IN predicates with equality for signed zero [flink] via GitHub
• 2026/09/17 [jira] [Updated] (FLINK-40693) FLOAT/DOUBLE IN and NOT IN disagree with equality for signed zero Sergey Paryshev (Jira)
• 2026/09/17 [jira] [Updated] (FLINK-40693) FLOAT/DOUBLE IN and NOT IN disagree with equality for signed zero Sergey Paryshev (Jira)
• 2026/09/17 [jira] [Created] (FLINK-40693) FLOAT/DOUBLE IN and NOT IN disagree with equality for signed zero Sergey Paryshev (Jira)
• 2026/09/17 [jira] [Updated] (FLINK-40684) [Model] Tensor names are unconditionally uppercased Danish (Jira)
• 2026/09/17 [jira] [Updated] (FLINK-40692) [Model] Use default model version from server when no version is defined in model config Danish (Jira)
• 2026/09/17 [jira] [Created] (FLINK-40692) [Model] Use default model version from server when no version is defined in model config Danish (Jira)
• 2026/09/17 [jira] [Resolved] (FLINK-40691) Fix comparison logic for binlog filename with more than 6 digits Yanquan Lv (Jira)
• 2026/09/17 Re: [PR] [FLINK-40136][Connectors/Kafka] Fix flaky ConcurrentModificationException in DynamicKafkaSourceEnumeratorTest [flink-connector-kafka] via GitHub
• 2026/09/17 [jira] [Created] (FLINK-40691) Fix comparison logic for binlog filename with more than 6 digits Yanquan Lv (Jira)
• 2026/09/17 Re: [D] Planning Flink Agents 0.3 [flink-agents] via GitHub
• 2026/09/17 Re: [D] Mem0 Backend for Long-Term Memory [flink-agents] via GitHub
• 2026/09/17 Re: [D] Label-Based Version Control Strategy [flink-agents] via GitHub
• 2026/09/17 Re: [D] Comprehensive Memory Management for Flink-Agents [flink-agents] via GitHub
• 2026/09/17 Re: [PR] [draft][api][integrations][java][python] Ask each connection whether it could apply a schema natively [flink-agents] via GitHub
• 2026/09/17 Re: [D] [Discussion][Observability 2/2] Built-in Operational Metrics for Flink Agents [flink-agents] via GitHub
• 2026/09/17 Re: [PR] [runtime][plan][python] Add built-in operational metrics [flink-agents] via GitHub
• 2026/09/17 [jira] [Closed] (FLINK-20969) Update Scala 2.12 version to 2.12.15 Martijn Visser (Jira)
• 2026/09/17 Re: [PR] [docs] Add Model Routing user documentation [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 [jira] [Assigned] (FLINK-40689) Kafka sink checkpoint recovery fails after producer epoch rollover with transaction V2 Roman Khachatryan (Jira)
• 2026/09/17 [jira] [Comment Edited] (FLINK-40083) Launch the SeaweedFS S3 test backend via weed mini and bump the image to 4.38 Martijn Visser (Jira)
• 2026/09/17 [jira] [Updated] (FLINK-40690) Fluss sink applies top-level column mapping to nested ROW fields ASF GitHub Bot (Jira)
• 2026/09/17 [PR] [FLINK-40690][pipeline-connector/fluss] Preserve nested row field positions [flink-cdc] 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] [Created] (FLINK-40690) Fluss sink applies top-level column mapping to nested ROW fields Xiaobing Fang (Jira)
• 2026/09/17 Re: [PR] [FLINK-40623][cdc-base] Release chunk splitter JDBC connection once a table is split [flink-cdc] via GitHub
• 2026/09/17 Re: [PR] [FLINK-36736][table] Fix target columns for row-level updates [flink] via GitHub
• 2026/09/17 Re: [PR] [hotfix][transform] Preserve table comments through transform [flink-cdc] via GitHub
• 2026/09/17 [jira] [Resolved] (FLINK-40083) Launch the SeaweedFS S3 test backend via weed mini and bump the image to 4.38 Martijn Visser (Jira)
• 2026/09/17 Re: [PR] [FLINK-40083][tests] Launch the SeaweedFS S3 test backend via 'weed mini' and bump to 4.47 [flink] via GitHub
• 2026/09/17 Re: [PR] [FLINK-39115][s3] Support URI Handling Utility [flink] via GitHub
• 2026/09/17 [jira] [Closed] (FLINK-39031) [PyFlink] support Python 3.13 and 3.14 Dian Fu (Jira)
• 2026/09/17 [jira] [Updated] (FLINK-39031) Support Python 3.13 Dian Fu (Jira)
• 2026/09/17 [jira] [Assigned] (FLINK-39031) Support Python 3.13 Dian Fu (Jira)
• 2026/09/17 [jira] [Updated] (FLINK-39031) Support Python 3.13 Dian Fu (Jira)
• 2026/09/17 Re: [PR] [FLINK-39031][python] Build pyflink wheels for Python 3.13 [flink] via GitHub
• 2026/09/17 Re: [PR] [FLINK-36736][table] Fix target columns for row-level updates [flink] via GitHub
• 2026/09/17 Re: [PR] [hotfix][docs] Fix grammar in DROP FUNCTION documentation [flink] via GitHub
• 2026/09/17 Re: [PR] [hotfix] Fix pipeline e2e CI compilation failure [flink-cdc] via GitHub
• 2026/09/17 Re: [PR] [hotfix][docs] Fix grammar in DROP FUNCTION documentation [flink] via GitHub
• 2026/09/17 Re: [PR] [hotfix][connect/mysql] Fix potential comparison failure when PK is VARBINARY [flink-cdc] via GitHub
• 2026/09/17 [PR] [hotfix][test][sqlserver] Shift test timestamps to avoid Debezium time-type conversion bug [flink-cdc] via GitHub
• 2026/09/17 Re: [PR] [FLINK-36735][table] Include updated columns when sink declares partial required columns for row-level update [flink] via GitHub
• 2026/09/17 [I] [Bug][plan] sub-agent cannot be rebuilt on a remote task after plan serialization [flink-agents] via GitHub
• 2026/09/17 Re: [PR] [hotfix][docs] Fix grammar in DROP FUNCTION documentation [flink] via GitHub
• 2026/09/17 [PR] [api][plan][runtime][python] Rebuild registered sub-agent setups from descriptors [flink-agents] via GitHub
• 2026/09/16 Re: [PR] [FLINK-36735][table] Include updated columns when sink declares partial required columns for row-level update [flink] via GitHub
• 2026/09/16 [PR] [hotfix][docs] Fix grammar in DROP FUNCTION documentation [flink] via GitHub
• 2026/09/16 [jira] [Commented] (FLINK-40673) INTERSECT ALL and EXCEPT ALL fail with mixed INT/BIGINT inputs Hesanda Liyanage (Jira)
• 2026/09/16 Re: [PR] [api][runtime][java][python] Add composable durable futures [flink-agents] via GitHub
• 2026/09/16 Re: [PR] [hotfix][route] Revert strict route rule regex matching case sensitivity [flink-cdc] via GitHub
• 2026/09/16 Re: [PR] [FLINK-40647][runtime] Support best-effort schema expansion for existing sink tables during table creation [flink-cdc] via GitHub
• 2026/09/16 Re: [PR] [FLINK-6417][connector/filesystem] Support glob paths in FileSource [flink] via GitHub
• 2026/09/16 Re: [I] [Feature] Apply structured output to an agent's final output only [flink-agents] via GitHub
• 2026/09/16 Re: [PR] [hotfix] Fix pipeline e2e CI compilation failure [flink-cdc] via GitHub
• 2026/09/16 Re: [PR] [hotfix][transform] Preserve table comments through transform [flink-cdc] via GitHub
• 2026/09/16 Re: [PR] [FLINK-6417][connector/filesystem] Support glob paths in FileSource [flink] via GitHub
• 2026/09/16 Re: [PR] [FLINK-40623][cdc-base] Release chunk splitter JDBC connection once a table is split [flink-cdc] via GitHub
• 2026/09/16 Re: [PR] [FLINK-40623][cdc-base] Release chunk splitter JDBC connection once a table is split [flink-cdc] via GitHub
• 2026/09/16 Re: [PR] [hotfix][runtime] Fix unable to take __data_event_type__ from REPLACE events [flink-cdc] via GitHub
• 2026/09/16 [PR] [hotfix] Fix pipeline e2e CI compilation failure [flink-cdc] via GitHub
• 2026/09/16 [PR] [FLINK-6417][connector/filesystem] Support glob paths in FileSource [flink] via GitHub
• 2026/09/16 Re: [PR] [api][java][python] Name the model the capability predicate judges [flink-agents] via GitHub

• Earlier messages
• Later messages