issues  

Messages by Date

• 2026/09/02 Re: [PR] [FLINK-40528][table] Make codegen tolerant to partial deletes [flink] via GitHub
• 2026/09/02 Re: [PR] [api][runtime][java][python] Require HTTPS and add digest pinning for URL skill sources [flink-agents] via GitHub
• 2026/09/02 Re: [PR] [FLINK-40513][runtime] Introduce multimodal AI functions for image understanding [flink-cdc] via GitHub
• 2026/09/02 Re: [PR] [FLINK-40512][postgres] Cache typeRegistry to reduce the busy work on inferring schema change event [flink-cdc] via GitHub
• 2026/09/02 Re: [PR] [api][java][python] Record embedding token usage metrics [flink-agents] via GitHub
• 2026/09/02 Re: [PR] [Feature][api][runtime] Support auto resolve memory reference for passing data across actions. [flink-agents] via GitHub
• 2026/09/02 [jira] [Updated] (FLINK-40512) PostgreSQL yaml source is busy on inferring schema change event Hongshun Wang (Jira)
• 2026/09/02 [jira] [Updated] (FLINK-40512) PostgreSQL source emits relation schema events for tables outside the configured table list Hongshun Wang (Jira)
• 2026/09/02 Re: [PR] [FLINK-40477][table] Fix constraint enforcer for partial deletes [flink] via GitHub
• 2026/09/02 [jira] [Updated] (FLINK-40477) Partial deletes fail sink NOT NULL enforcement ASF GitHub Bot (Jira)
• 2026/09/02 [PR] [FLINK-40477][table] Fix constraint enforcer for partial deletes [flink] via GitHub
• 2026/09/02 Re: [PR] [FLINK-40513][runtime] Introduce multimodal AI functions for image understanding [flink-cdc] via GitHub
• 2026/09/02 Re: [PR] [plan][java][python] Reject unsafe Bash redirects [flink-agents] via GitHub
• 2026/09/02 Re: [PR] [FLINK-40496][table-planner] Apply append-only column rules consistently when altering a materialized table [flink] via GitHub
• 2026/09/02 Re: [PR] [FLINK-35515][hive] Add Hive 4 support to the Flink Hive connector [flink-connector-hive] via GitHub
• 2026/09/01 Re: [PR] [runtime][plan][python] Add built-in operational metrics [flink-agents] via GitHub
• 2026/09/01 Re: [PR] [hotfix] Replace deprecated Flink, JOSDK, and fabric8 APIs [flink-kubernetes-operator] via GitHub
• 2026/09/01 Re: [PR] [FLINK-39095][docs] Document EXPLAIN CHANGELOG_MODE for streaming queries [flink] via GitHub
• 2026/09/01 Re: [PR] [FLINK-39092][SQL] Enhance EXPLAIN plan to display watermark specification [flink] via GitHub
• 2026/09/01 Re: [PR] [FLINK-38242] Improve upgrading documentation for SQL/Table API state compatibility and add Flink 2.x to compatibility table [flink] via GitHub
• 2026/09/01 Re: [PR] [FLINK-39092][SQL] Enhance EXPLAIN plan to display watermark specification [flink] via GitHub
• 2026/09/01 Re: [PR] [FLINK-40496][table-planner] Apply append-only column rules consistently when altering a materialized table [flink] via GitHub
• 2026/09/01 Re: [PR] [api][plan][python][examples] Framework-managed LLM-as-judge routing (Strategies.llm) [flink-agents] via GitHub
• 2026/09/01 Re: [PR] [FLINK-40491][core] Extend BinaryVariant with TIME, TIMESTAMP_NS, TIMESTAMP_LTZ_NS primitives [flink] via GitHub
• 2026/09/01 Re: [I] [Tech Debt] Non-happy-path response handling diverges between Java and Python in OpenAI-family connections [flink-agents] via GitHub
• 2026/09/01 Re: [PR] [FLINK-40496][table-planner] Apply append-only column rules consistently when altering a materialized table [flink] via GitHub
• 2026/09/01 Re: [PR] [plan][runtime] Do not retry or persist interrupted chat calls on cancellation [flink-agents] via GitHub
• 2026/09/01 Re: [PR] [api][runtime][java][python] Require HTTPS and add digest pinning for URL skill sources [flink-agents] via GitHub
• 2026/09/01 Re: [PR] [api][plan][runtime] Introduce AGENT resource type and sub-agent invocation API [flink-agents] via GitHub
• 2026/09/01 Re: [PR] [FLINK-40536][build] Bump cyclonedx-maven-plugin to 2.9.3 [flink] via GitHub
• 2026/09/01 [jira] [Updated] (FLINK-40536) Bump cyclonedx maven plugin to 2.9.2+ ASF GitHub Bot (Jira)
• 2026/09/01 [PR] [FLINK-40536][build] Bump cyclonedx-maven-plugin to 2.9.3 [flink] via GitHub
• 2026/09/01 [jira] [Created] (FLINK-40536) Bump cyclonedx maven plugin to 2.9.2+ Sergey Nuyanzin (Jira)
• 2026/09/01 Re: [PR] [integrations][plan] Handle finish_reason in OpenAI-family connections [flink-agents] via GitHub
• 2026/09/01 [jira] [Commented] (FLINK-40197) Add sql bindings to DataFrame API Dian Fu (Jira)
• 2026/09/01 Re: [PR] [FLINK-40197][python] Add sql() to the DataFrame API [flink] via GitHub
• 2026/09/01 Re: [PR] [FLINK-40513][runtime] Introduce multimodal AI functions for image understanding [flink-cdc] via GitHub
• 2026/09/01 Re: [PR] [FLINK-40533] Upgrade supported Flink versions to 2.3 [flink-cdc] via GitHub
• 2026/09/01 Re: [PR] [FLINK-40289][docs] Clarify watermark requirements in Window Top-N examples [flink] via GitHub
• 2026/09/01 Re: [PR] [hotfix][java][python] Harden Bash arithmetic evaluation [flink-agents] via GitHub
• 2026/09/01 [jira] [Assigned] (FLINK-40423) Add Top-N support to DataFrame API Dian Fu (Jira)
• 2026/09/01 [jira] [Commented] (FLINK-40423) Add Top-N support to DataFrame API Dian Fu (Jira)
• 2026/09/01 [jira] [Updated] (FLINK-40533) Upgrade Flink CDC dependency to Flink 2.3 ASF GitHub Bot (Jira)
• 2026/09/01 Re: [PR] [FLINK-40533] Upgrade supported Flink versions to 2.3 [flink-cdc] via GitHub
• 2026/09/01 Re: [PR] [FLINK-40128][connector][static-source] Implement Topic integrity checks [flink-connector-kafka] via GitHub
• 2026/09/01 Re: [PR] [FLINK-40463][table] Widen JSON_VALUE and JSON_QUERY RETURNING type support [flink] via GitHub
• 2026/09/01 Re: [PR] [FLINK-40218][core] Allow building a Variant from a token source [flink] via GitHub
• 2026/09/01 Re: [PR] [FLINK-40218][core] Allow building a Variant from a token source [flink] via GitHub
• 2026/09/01 Re: [PR] [FLINK-40218][core] Allow building a Variant from a token source [flink] via GitHub
• 2026/09/01 Re: [PR] [FLINK-40218][core] Allow building a Variant from a token source [flink] via GitHub
• 2026/09/01 Re: [PR] [FLINK-40137] Extract ReaderRecoveryGate from DynamicKafkaSourceEnumerator [flink-connector-kafka] via GitHub
• 2026/09/01 Re: [PR] [FLINK-40463][table] Widen JSON_VALUE and JSON_QUERY RETURNING type support [flink] via GitHub
• 2026/09/01 [jira] [Created] (FLINK-40534) Memory tuning config overrides are computed before the ScalingExecutorPlugin chain and persisted unchanged when a plugin modifies the scaling decision Shubhankar Sunil Unhale (Jira)
• 2026/09/01 [jira] [Updated] (FLINK-40535) Standalone session clusters are redeployed instead of scaled in-place ASF GitHub Bot (Jira)
• 2026/09/01 [PR] [FLINK-40535] Standalone session clusters are redeployed instead of scaled in-place [flink-kubernetes-operator] via GitHub
• 2026/09/01 Re: [PR] [FLINK-40491][core] Extend BinaryVariant with TIME, TIMESTAMP_NS, TIMESTAMP_LTZ_NS primitives [flink] via GitHub
• 2026/09/01 [jira] [Created] (FLINK-40535) Standalone session clusters are redeployed instead of scaled in-place Dennis-Mircea Ciupitu (Jira)
• 2026/09/01 Re: [PR] [FLINK-40517][checkpointing] Aggregate cross-channel watermarks on the recovery unspilling thread for fan-in rescale [flink] via GitHub
• 2026/09/01 Re: [PR] [FLINK-40520][checkpointing] Release spilled channel state on recovery abort between fetch and drain [flink] via GitHub
• 2026/09/01 Re: [PR] [FLINK-40530][runtime-web] Isolate per-entry failures in job overview aggregation [flink] via GitHub
• 2026/09/01 [PR] [FLINK-40513][runtime] Introduce multimodal AI functions for image understanding [flink-cdc] via GitHub
• 2026/09/01 [jira] [Updated] (FLINK-40520) Recovered channel-state spill files leak when recovery aborts between fetch and drain ASF GitHub Bot (Jira)
• 2026/09/01 [jira] [Updated] (FLINK-40517) Checkpointing-during-recovery drops cross-channel watermark / watermark-status aggregation on fan-in rescale ASF GitHub Bot (Jira)
• 2026/09/01 [PR] [FLINK-40517][checkpointing] Aggregate cross-channel watermarks on the recovery unspilling thread for fan-in rescale [flink] via GitHub
• 2026/09/01 [PR] [FLINK-40520][checkpointing] Release spilled channel state on recovery abort between fetch and drain [flink] via GitHub
• 2026/09/01 Re: [PR] [FLINK-40491][core] Extend BinaryVariant with TIME, TIMESTAMP_NS, TIMESTAMP_LTZ_NS primitives [flink] via GitHub
• 2026/09/01 Re: [PR] [FLINK-40463][table] Widen JSON_VALUE and JSON_QUERY RETURNING type support [flink] via GitHub
• 2026/09/01 [jira] [Updated] (FLINK-40463) Widen JSON_VALUE and JSON_QUERY RETURNING type support ASF GitHub Bot (Jira)
• 2026/09/01 [PR] [FLINK-40463][table] Widen JSON_VALUE and JSON_QUERY RETURNING type support [flink] via GitHub
• 2026/09/01 Re: [PR] [FLINK-40282][docs] Expand and correct the concepts Glossary [flink] via GitHub
• 2026/09/01 [jira] [Updated] (FLINK-40520) Recovered channel-state spill files leak when recovery aborts between fetch and drain Rui Fan (Jira)
• 2026/09/01 Re: [PR] [FLINK-30975][filesystems] Upgrade to Hadoop to 3.4.3 and support AWS SDK v2 in flink-filesystem [flink] via GitHub
• 2026/09/01 Re: [PR] [FLINK-40512][postgres] PostgreSQL source only emits relation schema events matching table filter. [flink-cdc] via GitHub
• 2026/09/01 [jira] [Created] (FLINK-40532) [DOC] Remove experimental warning from scan.parse.online.schema.changes.enabled VISHAL B (Jira)
• 2026/09/01 [jira] [Commented] (FLINK-40463) Widen JSON_VALUE and JSON_QUERY RETURNING type support Chris Johnson (Jira)
• 2026/09/01 Re: [PR] [FLINK-40218][core] Allow building a Variant from a token source [flink] via GitHub
• 2026/09/01 Re: [PR] [FLINK-40197][python] Add sql() to the DataFrame API [flink] via GitHub
• 2026/09/01 [jira] [Commented] (FLINK-40423) Add Top-N support to DataFrame API Timo Theusner (Jira)
• 2026/09/01 Re: [PR] [FLINK-40218][core] Allow building a Variant from a token source [flink] via GitHub
• 2026/09/01 Re: [PR] [FLINK-40218][core] Allow building a Variant from a token source [flink] via GitHub
• 2026/09/01 Re: [PR] [FLINK-40218][core] Allow building a Variant from a token source [flink] via GitHub
• 2026/09/01 Re: [PR] [FLINK-40218][core] Allow building a Variant from a token source [flink] via GitHub
• 2026/09/01 Re: [PR] [FLINK-40528][table] Make codegen tolerant to partial deletes [flink] via GitHub
• 2026/09/01 [jira] [Resolved] (FLINK-40507) upgrade paimon to 2.0.0 Xiqian Yu (Jira)
• 2026/09/01 Re: [PR] [FLINK-40019][core][runtime] Support per-job delegation tokens [flink] via GitHub
• 2026/09/01 Re: [PR] [FLINK-40019][core][runtime] Support per-job delegation tokens [flink] via GitHub
• 2026/09/01 [jira] [Created] (FLINK-40533) Upgrade Flink CDC dependency to Flink 2.3 Xiqian Yu (Jira)
• 2026/09/01 [PR] [hotfix][java][python] Harden Bash arithmetic evaluation [flink-agents] via GitHub
• 2026/09/01 Re: [PR] [FLINK-40218][core] Allow building a Variant from a token source [flink] via GitHub
• 2026/09/01 Re: [PR] [FLINK-40218][core] Allow building a Variant from a token source [flink] via GitHub
• 2026/09/01 Re: [PR] [FLINK-40019][core][runtime] Support per-job delegation tokens [flink] via GitHub
• 2026/09/01 Re: [PR] [api][plan][runtime] Introduce AGENT resource type and sub-agent invocation API [flink-agents] via GitHub
• 2026/09/01 [jira] [Created] (FLINK-40531) K8s Operator Autoscaler Parallelism overrides serialized in standard-YAML format break the deployed job Juliusz Nadberezny (Jira)
• 2026/09/01 [I] [Feature] Introduce subagent framework and AGENT resource type [flink-agents] via GitHub
• 2026/09/01 Re: [PR] [api][plan][runtime] Introduce AGENT resource type and sub-agent invocation API [flink-agents] via GitHub
• 2026/09/01 Re: [PR] [FLINK-39136] [flink-gs-fs-hadoop] bump com.google.cloud:google-cloud-storage from 2.29.1 to 2.62.1 [flink] via GitHub
• 2026/09/01 [PR] FLINK-40531 Serialize parallelism overrides in a version-portable format [flink-kubernetes-operator] via GitHub
• 2026/09/01 Re: [PR] [FLINK-40416][runtime] Add built-in text AI functions [flink-cdc] via GitHub
• 2026/09/01 [jira] [Updated] (FLINK-40496) CREATE OR ALTER MATERIALIZED TABLE applies column-change rules inconsistently with ALTER ... AS and can silently reorder existing columns Arvid Heise (Jira)
• 2026/09/01 [jira] [Updated] (FLINK-40496) CREATE OR ALTER MATERIALIZED TABLE applies column-change rules inconsistently with ALTER ... AS and can silently reorder existing columns Arvid Heise (Jira)
• 2026/09/01 Re: [PR] [FLINK-40491][core] Extend BinaryVariant with TIME, TIMESTAMP_NS, TIMESTAMP_LTZ_NS primitives [flink] via GitHub
• 2026/09/01 Re: [PR] [FLINK-40491][core] Extend BinaryVariant with TIME, TIMESTAMP_NS, TIMESTAMP_LTZ_NS primitives [flink] via GitHub
• 2026/09/01 [jira] [Updated] (FLINK-40513) Introduce multimodal AI functions for image understanding Mao Jiayi (Jira)
• 2026/09/01 [jira] [Reopened] (FLINK-40513) Introduce multimodal AI functions for image understanding Mao Jiayi (Jira)
• 2026/09/01 Re: [PR] [FLINK-40218][core] Allow building a Variant from a token source [flink] via GitHub
• 2026/09/01 Re: [PR] [FLINK-40218][core] Allow building a Variant from a token source [flink] via GitHub
• 2026/09/01 [jira] [Closed] (FLINK-40486) Introduce the UUID logical type Gustavo de Morais (Jira)
• 2026/09/01 Re: [PR] [FLINK-40136] Fix flaky ConcurrentModificationException in DynamicKafkaSourceEnumeratorTest [flink-connector-kafka] via GitHub
• 2026/09/01 Re: [PR] [FLINK-40486][table] Introduce the UUID logical type [flink] via GitHub
• 2026/09/01 [jira] [Updated] (FLINK-40531) K8s Operator Autoscaler Parallelism overrides serialized in standard-YAML format break the deployed job ASF GitHub Bot (Jira)
• 2026/09/01 [jira] [Resolved] (FLINK-40416) Add built-in text AI functions to Pipeline transforms Xiqian Yu (Jira)
• 2026/09/01 [jira] [Closed] (FLINK-40075) Optimize WELFORD_M2 aggregate accumulator by using RowData instead of STRUCTURED POJO accumulator dylanhz (Jira)
• 2026/09/01 Re: [PR] [FLINK-40218][core] Allow building a Variant from a token source [flink] via GitHub
• 2026/09/01 [jira] [Commented] (FLINK-40075) Optimize WELFORD_M2 aggregate accumulator by using RowData instead of STRUCTURED POJO accumulator dylanhz (Jira)
• 2026/09/01 Re: [PR] [FLINK-40524][network] Skip the recoveredBuffers monitor on the getNextBuffer hot path for channels that never recover [flink] via GitHub
• 2026/09/01 Re: [PR] [FLINK-37094][hive] Adapt Hive connector to Flink 2.0 API changes [flink-connector-hive] via GitHub
• 2026/09/01 [jira] [Commented] (FLINK-40516) Needed to support network policy in Jobmanager and Task Manager Taranpreet Kaur (Jira)
• 2026/09/01 Re: [PR] [FLINK-39136] [flink-gs-fs-hadoop] bump com.google.cloud:google-cloud-storage from 2.29.1 to 2.62.1 [flink] via GitHub
• 2026/09/01 Re: [PR] [FLINK-40491][core] Extend BinaryVariant with TIME, TIMESTAMP_NS, TIMESTAMP_LTZ_NS primitives [flink] via GitHub
• 2026/09/01 Re: [PR] [FLINK-40491][core] Extend BinaryVariant with TIME, TIMESTAMP_NS, TIMESTAMP_LTZ_NS primitives [flink] via GitHub
• 2026/09/01 Re: [PR] [FLINK-40491][core] Extend BinaryVariant with TIME, TIMESTAMP_NS, TIMESTAMP_LTZ_NS primitives [flink] via GitHub
• 2026/09/01 Re: [PR] [FLINK-40491][core] Extend BinaryVariant with TIME, TIMESTAMP_NS, TIMESTAMP_LTZ_NS primitives [flink] via GitHub
• 2026/09/01 Re: [PR] [FLINK-39986][table-planner][python] Support full-tree CSE for nested Python UDF calls [flink] via GitHub
• 2026/09/01 [jira] [Assigned] (FLINK-40017) Introduce Seaweedfs in native-s3-fs Gabor Somogyi (Jira)
• 2026/09/01 [jira] [Commented] (FLINK-40017) Introduce Seaweedfs in native-s3-fs Samrat Deb (Jira)
• 2026/09/01 [jira] [Closed] (FLINK-40017) Introduce Seaweedfs in native-s3-fs Samrat Deb (Jira)
• 2026/09/01 Re: [PR] [FLINK-40197][python] Add sql() to the DataFrame API [flink] via GitHub
• 2026/09/01 Re: [PR] [FLINK-40197][python] Add sql() to the DataFrame API [flink] via GitHub
• 2026/09/01 Re: [PR] [FLINK-40491][core] Extend BinaryVariant with TIME, TIMESTAMP_NS, TIMESTAMP_LTZ_NS primitives [flink] via GitHub
• 2026/09/01 Re: [PR] [FLINK-40017] Introduce Seaweedfs in native-s3-fs [flink] via GitHub
• 2026/09/01 Re: [PR] [FLINK-40491][core] Extend BinaryVariant with TIME, TIMESTAMP_NS, TIMESTAMP_LTZ_NS primitives [flink] via GitHub
• 2026/08/31 Re: [PR] [FLINK-39136] [flink-gs-fs-hadoop] bump com.google.cloud:google-cloud-storage from 2.29.1 to 2.62.1 [flink] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40445] Autoscaler: integration test for Kafka/Pulsar source partition-metric detection [flink-kubernetes-operator] via GitHub
• 2026/08/31 [PR] [tools][ci] Fix the bats suite's boundary with the scripts it tests [flink-agents] via GitHub
• 2026/08/31 Re: [PR] [runtime][api] Scope long-term memory operations to the action that obtained the memory set [flink-agents] via GitHub
• 2026/08/31 Re: [PR] [integrations][anthropic] Stop sending rejected sampling parameters [flink-agents] via GitHub
• 2026/08/31 Re: [PR] [runtime][plan][python] Add built-in operational metrics [flink-agents] via GitHub
• 2026/08/31 Re: [PR] [runtime][plan][python] Add built-in operational metrics [flink-agents] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40530][runtime-web] Isolate per-entry failures in job overview aggregation [flink] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40530][runtime-web] Isolate per-entry failures in job overview aggregation [flink] via GitHub
• 2026/08/31 [PR] [FLINK-40530][runtime-web] Isolate per-entry failures in job overview aggregation [flink] via GitHub
• 2026/08/31 [jira] [Updated] (FLINK-40530)  HistoryServerArchiveFetcher.updateJobOverview() aggregates all archived job overviews without per-entry error isolation, causing a single malformed archive to blank out the entire /jobs/overview response ASF GitHub Bot (Jira)
• 2026/08/31 [jira] [Created] (FLINK-40530)  HistoryServerArchiveFetcher.updateJobOverview() aggregates all archived job overviews without per-entry error isolation, causing a single malformed archive to blank out the entire /jobs/overview response Archit Goyal (Jira)
• 2026/08/31 [jira] [Updated] (FLINK-40529) PyFlink @Deprecated decorator warns at import time instead of on use Deepyaman Datta (Jira)
• 2026/08/31 Re: [PR] [FLINK-40529][python] Warn on use of deprecated APIs, not at import time [flink] via GitHub
• 2026/08/31 [jira] [Updated] (FLINK-40529) PyFlink @Deprecated decorator warns at import time instead of on use ASF GitHub Bot (Jira)
• 2026/08/31 [PR] [FLINK-40529][python] Warn on use of deprecated APIs, not at import time [flink] via GitHub
• 2026/08/31 [jira] [Created] (FLINK-40529) PyFlink @Deprecated decorator warns at import time instead of on use Deepyaman Datta (Jira)
• 2026/08/31 [I] [Tech Debt][API][Flink Integration] Simplify Agent output materialization to DataStream and Table [flink-agents] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40416][runtime] Add built-in text AI functions [flink-cdc] via GitHub
• 2026/08/31 [jira] [Commented] (FLINK-40421) Add sorting support in DataFrame API Hirson Zhang (Jira)
• 2026/08/31 Re: [PR] [FLINK-40512][postgres] PostgreSQL source only emits relation schema events matching table filter. [flink-cdc] via GitHub
• 2026/08/31 [jira] [Commented] (FLINK-40424) Add windowing TVF support to DataFrame API Dian Fu (Jira)
• 2026/08/31 [jira] [Assigned] (FLINK-40424) Add windowing TVF support to DataFrame API Dian Fu (Jira)
• 2026/08/31 Re: [PR] [FLINK-40507] Upgrade paimon to 2.0.0 [flink-cdc] via GitHub
• 2026/08/31 Re: [PR] [released] Add Flink-Shaded 22.0 [flink-web] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40528][table] Make codegen tolerat to partial deletes [flink] via GitHub
• 2026/08/31 [jira] [Updated] (FLINK-40528) Codegen should be tolerate to partial deletes ASF GitHub Bot (Jira)
• 2026/08/31 [PR] [FLINK-40528][table] Make codegen tolerat to partial deletes [flink] via GitHub
• 2026/08/31 [jira] [Created] (FLINK-40528) Codegen should be tolerate to partial deletes Sergey Nuyanzin (Jira)
• 2026/08/31 Re: [PR] [FLINK-40527] Update flink-shaded to 22.0 [flink] via GitHub
• 2026/08/31 [jira] [Updated] (FLINK-40527) Update flink-shaded to 22.0 ASF GitHub Bot (Jira)
• 2026/08/31 [PR] [FLINK-40527] Update flink-shaded to 22.0 [flink] via GitHub
• 2026/08/31 [jira] [Created] (FLINK-40527) Update flink-shaded to 22.0 Sergey Nuyanzin (Jira)
• 2026/08/31 [jira] [Resolved] (FLINK-40510) Use Apache Parent POM 39 Sergey Nuyanzin (Jira)
• 2026/08/31 [jira] [Commented] (FLINK-40510) Use Apache Parent POM 39 Sergey Nuyanzin (Jira)
• 2026/08/31 Re: [PR] [FLINK-40510][build] Bump Apache Parent pom to 39 [flink] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40510][build] Bump Apache Parent pom to 39 [flink] via GitHub
• 2026/08/31 Re: [PR] [FLINK-39837] Reassign retained dynamic Kafka offsets upon readd [flink-connector-kafka] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40355][table] Add new MAP_CONTAINS_KEY function [flink] via GitHub
• 2026/08/31 Re: [PR] [integrations][java][python] Apply Ollama native structured output [flink-agents] via GitHub
• 2026/08/31 [jira] [Created] (FLINK-40514) [Docs] Doris pipeline connector option table does not match implementation Rango (Jira)
• 2026/08/31 [PR] [FLINK-39570] Bump Netty to 4.1.136.Final (release-20.0) [flink-shaded] via GitHub
• 2026/08/31 Re: [PR] [integrations][anthropic] Update the stale default model to claude-sonnet-4-6 [flink-agents] via GitHub
• 2026/08/31 Re: [PR] [api][integrations][java][python] Raise a clear error for an output schema that cannot be rendered [flink-agents] via GitHub
• 2026/08/31 [jira] [Updated] (FLINK-40483) Support batch Top-N optimization for ROW_NUMBER() ASF GitHub Bot (Jira)
• 2026/08/31 Re: [PR] [FLINK-40486][table] Introduce the UUID logical type [flink] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40486][table] Introduce the UUID logical type [flink] via GitHub
• 2026/08/31 [jira] [Closed] (FLINK-40356) Add MAP_FROM_ENTRIES function Gustavo de Morais (Jira)
• 2026/08/31 [jira] [Updated] (FLINK-39813) [Connectors/Kinesis] Add lineage support to Kinesis Streams connector ASF GitHub Bot (Jira)
• 2026/08/31 Re: [PR] [FLINK-40486][table] Introduce the UUID logical type [flink] via GitHub
• 2026/08/31 [jira] [Updated] (FLINK-39137) Add configurable delay between non-empty GetRecords calls in Kinesis source Ferenc Csaky (Jira)
• 2026/08/31 Re: [PR] [FLINK-40491][core] Extend BinaryVariant with TIME, TIMESTAMP_NS, TIMESTAMP_LTZ_NS primitives [flink] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40137] Extract ReaderRecoveryGate from DynamicKafkaSourceEnumerator [flink-connector-kafka] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40483][table-planner] Convert batch ROW_NUMBER Top-N to two-stage Rank [flink] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40218][core] Allow building a Variant from a token source [flink] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40486][table] Introduce the UUID logical type [flink] via GitHub
• 2026/08/31 [jira] [Commented] (FLINK-40481) SHOW CREATE MATERIALIZED TABLE displays a future timestamp for FROM_NOW(<interval>) instead of past Arvid Heise (Jira)
• 2026/08/31 [jira] [Resolved] (FLINK-40481) SHOW CREATE MATERIALIZED TABLE displays a future timestamp for FROM_NOW(<interval>) instead of past Arvid Heise (Jira)
• 2026/08/31 Re: [PR] [FLINK-40519][network] Deliver priority barrier to a credited remote reader while the subpartition is blocked during recovery [flink] via GitHub
• 2026/08/31 [jira] [Updated] (FLINK-40519) Checkpoint-during-recovery barrier is not delivered to a credited remote reader while the subpartition is blocked ASF GitHub Bot (Jira)
• 2026/08/31 [PR] [FLINK-40525][network] Remove residual receivedBuffers lock in finishReadRecoveredState to avoid ABBA deadlock [flink] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40523][network] Compute tracePersist debug string only when trace logging is enabled [flink] via GitHub
• 2026/08/31 Re: [PR] [api][plan][python][examples] Framework-managed LLM-as-judge routing (Strategies.llm) [flink-agents] via GitHub
• 2026/08/31 [PR] [FLINK-40522][network] Deduplicate RecoveryCheckpointBarrier sentinel helpers shared by LocalInputChannel and RemoteInputChannel [flink] via GitHub
• 2026/08/31 [jira] [Reopened] (FLINK-38544) FLIP-547 V2: Filtering record before processing with spilling strategy Rui Fan (Jira)
• 2026/08/31 [PR] [FLINK-40483][table-planner] Convert batch ROW_NUMBER Top-N to two-stage Rank [flink] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40478][runtime-web] Log effective HistoryServer configuration at startup [flink] via GitHub
• 2026/08/31 [jira] [Updated] (FLINK-40524) LocalInputChannel.getNextBuffer takes the recoveredBuffers monitor on every buffer even when the channel never needed recovery ASF GitHub Bot (Jira)
• 2026/08/31 Re: [PR] [FLINK-34246][runtime] Add option to only archive failed jobs to history server [flink] via GitHub

• Earlier messages
• Later messages