issues  

Messages by Date

• 2026/09/13 [jira] [Assigned] (FLINK-40435) Add explode support to DataFrame API Dian Fu (Jira)
• 2026/09/13 [jira] [Commented] (FLINK-40429) Add StatementSet support for multi-sink DataFrame writes Dian Fu (Jira)
• 2026/09/13 [jira] [Assigned] (FLINK-40429) Add StatementSet support for multi-sink DataFrame writes Dian Fu (Jira)
• 2026/09/13 Re: [I] [Bug][runtime] Durable action-state keys collide for distinct events with identical attributes [flink-agents] via GitHub
• 2026/09/13 Re: [I] [Draft] [Bug] PythonActionExecutor leaks per-action Pemja PyObject references [flink-agents] via GitHub
• 2026/09/13 Re: [I] [Draft] [Bug] PythonActionExecutor leaks per-action Pemja PyObject references [flink-agents] via GitHub
• 2026/09/13 Re: [PR] [runtime][python] Release per-action Pemja objects [flink-agents] via GitHub
• 2026/09/13 Re: [PR] [runtime][python] Release per-action Pemja objects [flink-agents] via GitHub
• 2026/09/13 Re: [PR] [FLINK-40179] Support windowed states in state catalog [flink] via GitHub
• 2026/09/13 Re: [PR] [FLINK-39997] Upgrade pemja to 0.6.1 [flink] via GitHub
• 2026/09/13 Re: [PR] [FLINK-40597][core] Fix input type validation for Types.UUID [flink] via GitHub
• 2026/09/13 Re: [PR] [FLINK-20746][csv] Add csv.ignore-first-line for filesystem CSV connector [flink] via GitHub
• 2026/09/13 Re: [PR] [BP-2.3][FLINK-40592][metrics] Fix PushGateway basic authentication without JAXB [flink] via GitHub
• 2026/09/13 [PR] [integrations][watsonx] Support watsonx.ai native structured output [flink-agents] via GitHub
• 2026/09/13 [PR] [BP-2.3][FLINK-40592][metrics] Fix PushGateway basic authentication without JAXB [flink] via GitHub
• 2026/09/13 [jira] [Assigned] (FLINK-20746) Support ignore-first-line option for CSV format Leonard Xu (Jira)
• 2026/09/13 Re: [PR] [api][plan][python][examples] Framework-managed LLM-as-judge routing (Strategies.llm) [flink-agents] via GitHub
• 2026/09/13 [PR] [hotfix][ci] Pull the Milvus MinIO image from quay.io [flink-agents] via GitHub
• 2026/09/13 [PR] [hotfix][transform] Preserve table comments through transform [flink-cdc] via GitHub
• 2026/09/13 Re: [PR] [FLINK-40645][state/forst] Unregister closed streams from FileCacheEntry#openedStreams [flink] via GitHub
• 2026/09/13 Re: [PR] [FLINK-40644][state/forst] Close the remote stream when a CachedDataInputStream is closed [flink] via GitHub
• 2026/09/13 [jira] [Updated] (FLINK-40644) ForSt file cache: CachedDataInputStream.close() does not close the remote (original) stream, leaking S3A connections until the pool is exhausted ASF GitHub Bot (Jira)
• 2026/09/13 [jira] [Updated] (FLINK-40645) ForSt file cache: closed CachedDataInputStreams stay registered in FileCacheEntry.openedStreams until the file is evicted, accumulating on the heap ASF GitHub Bot (Jira)
• 2026/09/13 [PR] [FLINK-40645][state/forst] Unregister closed streams from FileCacheEntry#openedStreams [flink] via GitHub
• 2026/09/13 [PR] [FLINK-40644][state/forst] Close the remote stream when a CachedDataInputStream is closed [flink] via GitHub
• 2026/09/13 [jira] [Created] (FLINK-40645) ForSt file cache: closed CachedDataInputStreams stay registered in FileCacheEntry.openedStreams until the file is evicted, accumulating on the heap seungjoo choi (Jira)
• 2026/09/13 [jira] [Created] (FLINK-40644) ForSt file cache: CachedDataInputStream.close() does not close the remote (original) stream, leaking S3A connections until the pool is exhausted seungjoo choi (Jira)
• 2026/09/13 [jira] [Updated] (FLINK-40643) Do not use dowload/untar runs separately in flink-ci-docker ASF GitHub Bot (Jira)
• 2026/09/13 [jira] [Created] (FLINK-40643) Do not use dowload/untar runs separately in flink-ci-docker Sergey Nuyanzin (Jira)
• 2026/09/13 Re: [PR] [hotfix][opensearch3] Bump org.apache.httpcomponents.client5:httpclient5 from 5.6 to 5.6.4, opensearch-java to 3.10.0 [flink-connector-opensearch] via GitHub
• 2026/09/13 [jira] [Updated] (FLINK-40642) Flink ci docker build fails on Mac ASF GitHub Bot (Jira)
• 2026/09/13 [jira] [Created] (FLINK-40642) Flink ci docker build fails on Mac Sergey Nuyanzin (Jira)
• 2026/09/13 Re: [PR] [hotfix][opensearch3] Bump org.apache.httpcomponents.client5:httpclient5 from 5.6 to 5.6.4, opensearch-java to 3.10.0 [flink-connector-opensearch] via GitHub
• 2026/09/13 [jira] [Updated] (FLINK-29623) Migrate flink-metrics-prometheus off io.prometheus:simpleclient 0.8.1 Martijn Visser (Jira)
• 2026/09/13 [jira] [Updated] (FLINK-29623) Migrate flink-metrics-prometheus off io.prometheus:simpleclient 0.8.1 Martijn Visser (Jira)
• 2026/09/13 [jira] [Created] (FLINK-40641) Cover the Prometheus reporter exposition contract Martijn Visser (Jira)
• 2026/09/13 Re: [PR] [FLINK-40592][metrics] Fix PushGateway basic authentication without JAXB [flink] via GitHub
• 2026/09/13 [jira] [Commented] (FLINK-40592) PrometheusPushGatewayReporter fails to initialize with basic authentication Martijn Visser (Jira)
• 2026/09/13 Re: [PR] [FLINK-40640][iceberg] Fix duplicate rows when an UPDATE changes the partition value [flink-cdc] via GitHub
• 2026/09/13 Re: [PR] [bug][runtime] Derive durable-state action UUID from the plan-unique action name [flink-agents] via GitHub
• 2026/09/13 Re: [PR] Bump org.apache.logging.log4j:log4j-api from 2.24.1 to 2.25.5 [flink-connector-opensearch] via GitHub
• 2026/09/13 Re: [PR] [FLINK-40640][iceberg] Fix duplicate rows when an UPDATE changes the partition value [flink-cdc] via GitHub
• 2026/09/13 [PR] [FLINK-40640][iceberg] Fix duplicate rows when an UPDATE changes the partition value [flink-cdc] via GitHub
• 2026/09/13 Re: [PR] Bump org.apache.logging.log4j:log4j-api from 2.24.1 to 2.25.5 [flink-connector-opensearch] via GitHub
• 2026/09/13 [jira] [Updated] (FLINK-40640) [Iceberg] UPDATE that changes a partitioned column's value leaves a duplicate stale row in the old partition ASF GitHub Bot (Jira)
• 2026/09/13 [PR] [FLINK-40640][iceberg] Fix duplicate rows when an UPDATE changes the partition value [flink-cdc] via GitHub
• 2026/09/13 [jira] [Created] (FLINK-40640) [Iceberg] UPDATE that changes a partitioned column's value leaves a duplicate stale row in the old partition VISHAL B (Jira)
• 2026/09/13 [PR] [hotfix] Bump org.apache.httpcomponents.client5:httpclient5 from 5.6 to 5.6.3, opensearch-java to 3.10.0 [flink-connector-opensearch] via GitHub
• 2026/09/13 Re: [PR] Bump org.apache.httpcomponents.core5:httpcore5-h2 from 5.4.2 to 5.4.3 [flink-connector-opensearch] via GitHub
• 2026/09/13 Re: [PR] Bump org.apache.httpcomponents.core5:httpcore5-h2 from 5.4.2 to 5.4.3 [flink-connector-opensearch] via GitHub
• 2026/09/13 Re: [PR] Bump org.apache.httpcomponents.core5:httpcore5 from 5.4.2 to 5.4.3 [flink-connector-opensearch] via GitHub
• 2026/09/13 Re: [PR] Bump org.apache.httpcomponents.core5:httpcore5 from 5.4.2 to 5.4.3 [flink-connector-opensearch] via GitHub
• 2026/09/13 Re: [PR] [api][runtime][python] Add opt-in Kafka tombstones for pruned action state [flink-agents] via GitHub
• 2026/09/13 [jira] [Commented] (FLINK-40543) Race condition and ConcurrentModificationException in MockSplitEnumeratorContext.getSentSourceEvent() Qiu Yanjun (Jira)
• 2026/09/13 [jira] [Commented] (FLINK-40354) StateTtlConfig background cleanup does not work for async State v2 MapState on ForSt state backend seungjoo choi (Jira)
• 2026/09/13 [jira] [Commented] (FLINK-40623) [cdc-base] JdbcSourceChunkSplitter keeps a pooled JDBC connection for the whole job lifetime; with default connection.pool.size=20 the 21st incremental-snapshot job on the same JobManager can never start wglbd12 (Jira)
• 2026/09/13 Re: [PR] Bump org.apache.commons:commons-lang3 from 3.14.0 to 3.18.0 [flink-connector-opensearch] via GitHub
• 2026/09/13 [PR] [python] Use a reserved host in the redirect user-info test fixture [flink-agents] via GitHub
• 2026/09/13 [jira] [Updated] (FLINK-40623) [cdc-base] JdbcSourceChunkSplitter keeps a pooled JDBC connection for the whole job lifetime; with default connection.pool.size=20 the 21st incremental-snapshot job on the same JobManager can never start ASF GitHub Bot (Jira)
• 2026/09/13 Re: [PR] [FLINK-34251][core] ClosureCleaner to include reference classes for non-serialization exception [flink] via GitHub
• 2026/09/13 [PR] [FLINK-40623][cdc-base] Release chunk splitter JDBC connection once a table is split [flink-cdc] via GitHub
• 2026/09/13 Re: [I] [Tech Debt] Align Java and Python recovery model [flink-agents] via GitHub
• 2026/09/13 Re: [PR] [FLINK-40639][kubernetes] Deprecated kubernetes.pod-template-file takes precedence over kubernetes.pod-template-file.default [flink] via GitHub
• 2026/09/13 [jira] [Updated] (FLINK-40639) Deprecated kubernetes.pod-template-file takes precedence over kubernetes.pod-template-file.default ASF GitHub Bot (Jira)
• 2026/09/13 [PR] [FLINK-40639][kubernetes] Deprecated kubernetes.pod-template-file takes precedence over kubernetes.pod-template-file.default [flink] via GitHub
• 2026/09/13 [jira] [Updated] (FLINK-40639) Deprecated kubernetes.pod-template-file takes precedence over kubernetes.pod-template-file.default sepuri sai krishna (Jira)
• 2026/09/13 Re: [PR] [runtime][plan][python] Add built-in operational metrics [flink-agents] via GitHub
• 2026/09/12 Re: [PR] [api][runtime][python] Add opt-in Kafka tombstones for pruned action state [flink-agents] via GitHub
• 2026/09/12 [jira] [Created] (FLINK-40639) Deprecated kubernetes.pod-template-file takes precedence over kubernetes.pod-template-file.default sepuri sai krishna (Jira)
• 2026/09/12 Re: [PR] [FLINK-34251][core] ClosureCleaner to include reference classes for non-serialization exception [flink] via GitHub
• 2026/09/12 Re: [PR] [FLINK-39668] Add get kafka offsets SQL table function [flink-connector-kafka] via GitHub
• 2026/09/12 Re: [PR] [FLINK-39668] Add get kafka offsets SQL table function [flink-connector-kafka] via GitHub
• 2026/09/12 Re: [PR] [FLINK-39928][ci] If there are changes in tests only then skip non related CI jobs in GHA [flink] via GitHub
• 2026/09/12 Re: [PR] [FLINK-40578][table-runtime] `OVERLAY` discards the rest of the string and splits supplementary-plane characters [flink] via GitHub
• 2026/09/12 Re: [PR] [FLINK-40628][python] Avoid gateway launch during embedded TTL initialization [flink] via GitHub
• 2026/09/12 Re: [PR] [FLINK-40628][python] Avoid gateway launch during embedded TTL initialization [flink] via GitHub
• 2026/09/12 [jira] [Commented] (FLINK-40435) Add explode support to DataFrame API Bettle (Jira)
• 2026/09/12 [jira] [Commented] (FLINK-40429) Add StatementSet support for multi-sink DataFrame writes Bettle (Jira)
• 2026/09/12 [jira] [Commented] (FLINK-40420) Add set operations to DataFrame API Bettle (Jira)
• 2026/09/12 [jira] [Commented] (FLINK-40420) Add set operations to DataFrame API Bettle (Jira)
• 2026/09/12 Re: [PR] [FLINK-40420][python] Add set operations to DataFrame API [flink] via GitHub
• 2026/09/12 [jira] [Updated] (FLINK-40420) Add set operations to DataFrame API ASF GitHub Bot (Jira)
• 2026/09/12 [PR] [FLINK-40420][python] Add set operations to DataFrame API [flink] via GitHub
• 2026/09/12 Re: [PR] Bump org.apache.commons:commons-lang3 from 3.14.0 to 3.18.0 [flink-connector-opensearch] via GitHub
• 2026/09/12 Re: [PR] [FLINK-38592] Initial Native Flink S3 FileSystem [flink] via GitHub
• 2026/09/12 [jira] [Commented] (FLINK-40508) Support DB2 pipeline connector suntectec (Jira)
• 2026/09/12 [PR] [FLINK-40637][table] Expand catalog views hermetically against the view's own database [flink] via GitHub
• 2026/09/12 [PR] [FLINK-40508][pipeline-connector/db2] Support DB2 pipeline connector [flink-cdc] via GitHub
• 2026/09/12 Re: [PR] [FLINK-40637][table] Expand catalog views hermetically against the view's own database [flink] via GitHub
• 2026/09/12 Re: [PR] [FLINK-20746][csv] Add csv.ignore-first-line for filesystem CSV connector [flink] via GitHub
• 2026/09/12 Re: [PR] [FLINK-40551][tests] Select the checkpoint to restore by content in FileMergingChannelStateITCase [flink] via GitHub
• 2026/09/12 Re: [PR] [FLINK-40551][tests] Select the checkpoint to restore by content in FileMergingChannelStateITCase [flink] via GitHub
• 2026/09/12 [jira] [Updated] (FLINK-40637) Catalog view expansion falls back to the session database for unresolved references ASF GitHub Bot (Jira)
• 2026/09/12 Re: [PR] [FLINK-38592] Initial Native Flink S3 FileSystem [flink] via GitHub
• 2026/09/12 Re: [PR] [FLINK-38592] Initial Native Flink S3 FileSystem [flink] via GitHub
• 2026/09/12 Re: [PR] [FLINK-40418][python] Support attribute-based column access on DataFrame [flink] via GitHub
• 2026/09/12 [PR] [FLINK-40418][python] Support attribute-based column access on DataFrame [flink] via GitHub
• 2026/09/12 [jira] [Updated] (FLINK-40418) Support attribute-based column access on DataFrame ASF GitHub Bot (Jira)
• 2026/09/11 Re: [PR] [FLINK-35012][table] Fix flaky ChangelogNormalizeRestoreTest by adding padding records to prevent mini-batch merging [flink] via GitHub
• 2026/09/11 Re: [PR] [FLINK-40592][metrics] Fix PushGateway basic authentication without JAXB [flink] via GitHub
• 2026/09/11 Re: [PR] [FLINK-40592][metrics] Fix PushGateway basic authentication without JAXB [flink] via GitHub
• 2026/09/11 Re: [PR] FLIP-573: [DRAFT] Queues for Kafka [flink-connector-kafka] via GitHub
• 2026/09/11 [jira] [Created] (FLINK-40634) E2E are extremely slow in Azure Sergey Nuyanzin (Jira)
• 2026/09/11 [jira] [Created] (FLINK-40636) Add Maven/Aether connection timeouts to shared connector CI to avoid 50-minute hangs Sylwester Lachiewicz (Jira)
• 2026/09/11 Re: [PR] [FLINK-40277][connector-http] Add HTTP sink status-code handling and retries [flink-connector-http] via GitHub
• 2026/09/11 [jira] [Updated] (FLINK-40638) Add optional custom URL handlers for JobManager and TaskManager logs in the history server ASF GitHub Bot (Jira)
• 2026/09/11 Re: [PR] [FLINK-40277][connector-http] Add HTTP sink status-code handling and retries [flink-connector-http] via GitHub
• 2026/09/11 Re: [PR] [FLINK-40277][connector-http] Add HTTP sink status-code handling and retries [flink-connector-http] via GitHub
• 2026/09/11 [jira] [Updated] (FLINK-40398) flink-connector-kafka DynamicKafkaSourceReaderTest.testHandleSourceEventRetainsRemovedClusterOffsetsUntilExpired flakiness ASF GitHub Bot (Jira)
• 2026/09/11 Re: [PR] [runtime][java][skills] Bound download and extraction size [flink-agents] via GitHub
• 2026/09/11 Re: [PR] [FLINK-40578][table-runtime] `OVERLAY` discards the rest of the string and splits supplementary-plane characters [flink] via GitHub
• 2026/09/11 [jira] [Updated] (FLINK-40633) Make download-crt-jars.sh maven command agnostic ASF GitHub Bot (Jira)
• 2026/09/11 [jira] [Resolved] (FLINK-40631) table-planner: CalcRestoreTest calc-variant restore fails after Variant type evolution (serialVersionUID) Sergey Nuyanzin (Jira)
• 2026/09/11 [jira] [Updated] (FLINK-31080) Idle slots are not released due to a mismatch in time between DeclarativeSlotPoolService and SlotSharingSlotAllocator Bob Thomson (Jira)
• 2026/09/11 Re: [PR] [FLINK-40551][tests] Select the checkpoint to restore by content in FileMergingChannelStateITCase [flink] via GitHub
• 2026/09/11 Re: [PR] [FLINK-40557][table] Make operation column optional in `TO_CHANGELOG`… [flink] via GitHub
• 2026/09/11 Re: [PR] [FLINK-40633][s3] Allow overriding the Maven executable in download-crt-jars.sh [flink] via GitHub
• 2026/09/11 [jira] [Closed] (FLINK-40197) Add sql bindings to DataFrame API Dian Fu (Jira)
• 2026/09/11 Re: [PR] [FLINK-40632][s3] Annotate native-s3-fs to PublicEvolving [flink] via GitHub
• 2026/09/11 Re: [PR] [FLINK-40277][connector-http] Add HTTP sink status-code handling and retries [flink-connector-http] via GitHub
• 2026/09/11 Re: [PR] [FLINK-40629][ci] Keep the license check honest on Maven 3.9 [flink-connector-shared-utils] via GitHub
• 2026/09/11 [jira] [Updated] (FLINK-30277) Allow PYTHONPATH of Python Worker configurable Bob Thomson (Jira)
• 2026/09/11 Re: [PR] [FLINK-40197][python] Support UDF bindings in DataFrame sql() [flink] via GitHub
• 2026/09/11 [PR] [FLINK-40632][s3] Annotate native-s3-fs to PublicEvolving [flink] via GitHub
• 2026/09/11 Re: [PR] [FLINK-40592][metrics] Fix PushGateway basic authentication without JAXB [flink] via GitHub
• 2026/09/11 Re: [PR] [FLINK-40597][core] Fix input type validation for Types.UUID [flink] via GitHub
• 2026/09/11 [jira] [Updated] (FLINK-32239) Unify TestJvmProcess and TestProcessBuilder Bob Thomson (Jira)
• 2026/09/11 Re: [PR] [FLINK-40354][state/forst] Configure the TTL compaction filter for State V2 states [flink] via GitHub
• 2026/09/11 [jira] [Closed] (FLINK-34246) Allow only archive failed job to history server Robert Metzger (Jira)
• 2026/09/11 Re: [PR] [FLINK-40631][table-planner] Regenerate calc-variant restore savepoint after Variant type change [flink] via GitHub
• 2026/09/11 Re: [PR] [FLINK-40277][connector-http] Add HTTP sink status-code handling and retries [flink-connector-http] via GitHub
• 2026/09/11 [jira] [Updated] (FLINK-40551) FileMergingChannelStateITCase is very flaky ASF GitHub Bot (Jira)
• 2026/09/11 Re: [PR] [FLINK-40355][table] Add new MAP_CONTAINS_KEY function [flink] via GitHub
• 2026/09/11 [jira] [Updated] (FLINK-40632) Remove Experimental Annotation of Native S3 ASF GitHub Bot (Jira)
• 2026/09/11 Re: [PR] [FLINK-38262][table] show create connection operation [flink] via GitHub
• 2026/09/11 Re: [PR] [FLINK-39775][mysql] Release snapshot split metadata after entering the stream phase [flink-cdc] via GitHub
• 2026/09/11 Re: [PR] [FLINK-40592][metrics] Fix PushGateway basic authentication without JAXB [flink] via GitHub
• 2026/09/11 Re: [PR] [FLINK-40355][table] Add new MAP_CONTAINS_KEY function [flink] via GitHub
• 2026/09/11 Re: [PR] [FLINK-40424][table][python] Support windowing TVFs in the DataFrame API [flink] via GitHub
• 2026/09/11 [jira] [Updated] (FLINK-17037) add e2e tests for reading array data types from postgres with JDBCTableSource and PostgresCatalog Bob Thomson (Jira)
• 2026/09/11 Re: [PR] [FLINK-40586][Connectors/Kafka] Signal no more splits to each reader once per registration [flink-connector-kafka] via GitHub
• 2026/09/11 Re: [PR] [FLINK-40638][historyserver] Add optional custom URL handlers for JobManager and TaskManager logs in the history server [flink] via GitHub
• 2026/09/11 [jira] [Created] (FLINK-40638) Add optional custom URL handlers for JobManager and TaskManager logs in the history server Archit Goyal (Jira)
• 2026/09/11 Re: [PR] [FLINK-40552][runtime] Support asynchronous transform execution [flink-cdc] via GitHub
• 2026/09/11 [jira] [Assigned] (FLINK-40633) Make download-crt-jars.sh maven command agnostic Gabor Somogyi (Jira)
• 2026/09/11 [jira] [Resolved] (FLINK-40362) DynamicKafkaSource idle reader never finishes when no-more-splits precedes the metadata update Martijn Visser (Jira)
• 2026/09/11 [jira] [Assigned] (FLINK-34246) Allow only archive failed job to history server Robert Metzger (Jira)
• 2026/09/11 Re: [PR] [FLINK-34246][runtime] Add option to only archive failed jobs to history server [flink] via GitHub
• 2026/09/11 Re: [PR] [FLINK-40631][table] Pin `serialVersionUID` in `Variant` [flink] via GitHub
• 2026/09/11 Re: [PR] [FLINK-40489][table] Add UUID_V4() and UUID_V7() functions [flink] via GitHub
• 2026/09/11 [jira] [Commented] (FLINK-40420) Add set operations to DataFrame API Dian Fu (Jira)
• 2026/09/11 [jira] [Created] (FLINK-40633) Make download-crt-jars.sh maven command agnostic Gabor Somogyi (Jira)
• 2026/09/11 Re: [PR] [FLINK-40568][tests] Fix flaky ProcessTableFunctionSemanticTests by using materialized data assertion [flink] via GitHub
• 2026/09/11 [jira] [Updated] (FLINK-40592) PrometheusPushGatewayReporter fails to initialize with basic authentication Martijn Visser (Jira)
• 2026/09/11 Re: [PR] [FLINK-39115][s3] Support URI Handling Utility [flink] via GitHub
• 2026/09/11 Re: [PR] [FLINK-40493][table] Support casting from VARIANT to UUID [flink] via GitHub
• 2026/09/11 [PR] [FLINK-40398][connector/kafka] Inject a clock for retention expiry [flink-connector-kafka] via GitHub
• 2026/09/11 [jira] [Assigned] (FLINK-40592) PrometheusPushGatewayReporter fails to initialize with basic authentication Martijn Visser (Jira)
• 2026/09/11 [jira] [Created] (FLINK-40637) Catalog view expansion falls back to the session database for unresolved references Talat Uyarer (Jira)
• 2026/09/11 Re: [PR] [FLINK-40632][s3] Annotate native-s3-fs to PublicEvolving [flink] via GitHub
• 2026/09/11 [jira] [Created] (FLINK-40632) Remove Experimental Annotation of Native S3 Samrat Deb (Jira)
• 2026/09/11 [jira] [Updated] (FLINK-40636) Add Maven/Aether connection timeouts to shared connector CI to avoid 50-minute hangs ASF GitHub Bot (Jira)
• 2026/09/11 Re: [PR] [FLINK-40636][ci] Add Maven and Aether connection timeouts to avoid 50-minute hangs [flink-connector-shared-utils] via GitHub
• 2026/09/11 [jira] [Updated] (FLINK-40617) Connectors/Kafka: Prune and bump dependency versions in the root pom Purushottam Sinha (Jira)
• 2026/09/11 Re: [PR] [FLINK-40557][table] Make operation column optional in `TO_CHANGELOG`… [flink] via GitHub
• 2026/09/11 Re: [PR] [FLINK-40557][table] Make operation column optional in `TO_CHANGELOG`… [flink] via GitHub
• 2026/09/11 Re: [PR] [FLINK-40551][tests] Select the checkpoint to restore by content in FileMergingChannelStateITCase [flink] via GitHub
• 2026/09/11 Re: [PR] [FLINK-40179] Support windowed states in state catalog [flink] via GitHub
• 2026/09/11 [jira] [Commented] (FLINK-38798) Add Helm chart provenance (.prov) files for flink-kubernetes-operator releases Avi Sanwal (Jira)
• 2026/09/11 Re: [PR] [FLINK-40354][state/forst] Configure the TTL compaction filter for State V2 states [flink] via GitHub
• 2026/09/11 [jira] [Updated] (FLINK-39786) closeForCommit() leaks orphan multipart uploads on upload failure Bob Thomson (Jira)
• 2026/09/11 Re: [PR] [FLINK-40277][connector-http] Add HTTP sink status-code handling and retries [flink-connector-http] via GitHub
• 2026/09/11 Re: [PR] [FLINK-40493][table] Support casting from VARIANT to UUID [flink] via GitHub
• 2026/09/11 Re: [PR] [FLINK-40277][connector-http] Add HTTP sink status-code handling and retries [flink-connector-http] via GitHub
• 2026/09/11 Re: [PR] [FLINK-39115][s3] Support URI Handling Utility [flink] via GitHub
• 2026/09/11 Re: [PR] [FLINK-40234][runtime] Exclude synchronous downstream processing from source idleness accounting [flink] via GitHub
• 2026/09/11 Re: [PR] [FLINK-40559][clients] Honor --claimMode in application mode [flink] via GitHub
• 2026/09/11 Re: [PR] [FLINK-40493][table] Support casting from VARIANT to UUID [flink] via GitHub
• 2026/09/11 [jira] [Assigned] (FLINK-40420) Add set operations to DataFrame API Dian Fu (Jira)
• 2026/09/11 Re: [PR] [FLINK-40197][python] Support UDF bindings in DataFrame sql() [flink] via GitHub
• 2026/09/11 [jira] [Commented] (FLINK-40197) Add sql bindings to DataFrame API Dian Fu (Jira)
• 2026/09/11 Re: [PR] [FLINK-40493][table] Support casting from VARIANT to UUID [flink] via GitHub
• 2026/09/11 Re: [PR] [FLINK-40197][python] Support UDF bindings in DataFrame sql() [flink] via GitHub
• 2026/09/11 Re: [PR] [FLINK-40197][python] Support UDF bindings in DataFrame sql() [flink] via GitHub
• 2026/09/11 Re: [PR] [FLINK-40629][ci] Keep the license check honest on Maven 3.9 [flink-connector-shared-utils] via GitHub
• 2026/09/11 [jira] [Updated] (FLINK-40362) DynamicKafkaSource idle reader never finishes when no-more-splits precedes the metadata update Martijn Visser (Jira)
• 2026/09/11 [jira] [Comment Edited] (FLINK-40362) DynamicKafkaSource idle reader never finishes when no-more-splits precedes the metadata update Martijn Visser (Jira)
• 2026/09/11 Re: [PR] [BP-4.0][FLINK-40362][connector/kafka] Fix idle reader hang when no-more-splits precedes metadata update [flink-connector-kafka] via GitHub
• 2026/09/11 Re: [PR] [BP-3.4][FLINK-40362][connector/kafka] Fix idle reader hang when no-more-splits precedes metadata update [flink-connector-kafka] via GitHub
• 2026/09/11 Re: [PR] [BP-5.0][FLINK-40362][connector/kafka] Fix idle reader hang when no-more-splits precedes metadata update [flink-connector-kafka] via GitHub
• 2026/09/11 [PR] [FLINK-40493][table] Support casting from VARIANT to UUID [flink] via GitHub
• 2026/09/11 Re: [PR] [FLINK-40617] Bump jackson-bom, log4j, avro, commons, archunit, docker-java-api, guava, javassist, objenesis, snakeyaml, snappy-java [flink-connector-kafka] via GitHub
• 2026/09/11 [jira] [Updated] (FLINK-40493) VARIANT CAST for UUID (code 20) ASF GitHub Bot (Jira)
• 2026/09/11 [jira] [Assigned] (FLINK-40493) VARIANT CAST for UUID (code 20) Ramin Gharib (Jira)
• 2026/09/11 [jira] [Assigned] (FLINK-40493) VARIANT CAST for UUID (code 20) Ramin Gharib (Jira)
• 2026/09/11 [jira] [Commented] (FLINK-40551) FileMergingChannelStateITCase is very flaky Jira
• 2026/09/11 [jira] [Closed] (FLINK-40424) Add windowing TVF support to DataFrame API Dian Fu (Jira)
• 2026/09/11 Re: [PR] [FLINK-40424][table][python] Support windowing TVFs in the DataFrame API [flink] via GitHub
• 2026/09/11 Re: [PR] [FLINK-40197][python] Support UDF bindings in DataFrame sql() [flink] via GitHub
• 2026/09/11 [PR] [FLINK-40633][s3] Allow overriding the Maven executable in download-crt-jars.sh [flink] via GitHub

• Earlier messages
• Later messages