issues  

Messages by Date

• 2026/09/15 [jira] [Resolved] (FLINK-40665) cron_snapshot_deployment_maven fails the Maven version enforcer because deploy_staging_jars.sh uses the Maven on PATH Martijn Visser (Jira)
• 2026/09/15 [PR] [FLINK-39105][rest] Fix RestClientTest.testConnectionTimeout to handle environment-dependent exception types [flink] via GitHub
• 2026/09/15 [PR] [FLINK-39105][rest] Fix RestClientTest.testConnectionTimeout to handle environment-dependent exception types [flink] via GitHub
• 2026/09/15 [jira] [Commented] (FLINK-38727) Unstable test cases EventTimeWindowCheckpointingITCase.testPreAggregatedSlidingTimeWindow Martijn Visser (Jira)
• 2026/09/15 [jira] [Updated] (FLINK-39105) RestClientTest.testConnectionTimeout fails with different expected exception Martijn Visser (Jira)
• 2026/09/15 [jira] [Updated] (FLINK-40662) 'Run kubernetes Materialized Table test' fails on release-2.3 because the SQL Gateway returns a null session handle Martijn Visser (Jira)
• 2026/09/15 [jira] [Updated] (FLINK-40667) Buffer ref-count leaks in CDR recovery filtering end in free() on a live segment Rui Fan (Jira)
• 2026/09/15 Re: [PR] [FLINK-40655][runtime] Fix flaky partition release test [flink] via GitHub
• 2026/09/15 [jira] [Commented] (FLINK-38501) Tests crashed for Flink Runtime in test_cron_azure core Martijn Visser (Jira)
• 2026/09/15 [jira] [Updated] (FLINK-40662) 'Run kubernetes Materialized Table test' fails because the SQL Gateway returns a null session handle Martijn Visser (Jira)
• 2026/09/15 Re: [PR] [FLINK-40640][iceberg] Fix duplicate rows when an UPDATE changes the partition value [flink-cdc] via GitHub
• 2026/09/15 [jira] [Commented] (FLINK-40288) Multiple JoinSemanticTests fail Martijn Visser (Jira)
• 2026/09/15 [jira] [Commented] (FLINK-40655) ExecutionVertexTest.testResetForNewExecutionReleasesPartitions is unstable Martijn Visser (Jira)
• 2026/09/15 [jira] [Commented] (FLINK-39954) SinkV2ITCase over-asserts commit multiplicity under unaligned checkpoints Martijn Visser (Jira)
• 2026/09/15 [jira] [Closed] (FLINK-37727) java.lang.UnsatisfiedLinkError error on pemja.core.PythonInterpreter$MainInterpreter.initialize() Dian Fu (Jira)
• 2026/09/15 [jira] [Updated] (FLINK-40670) MultiJoinSemanticTests[four-way-mixed-join-multi-key-types-shuffled] loses a row on release-2.3 Martijn Visser (Jira)
• 2026/09/15 [jira] [Updated] (FLINK-40662) 'Run kubernetes Materialized Table test' fails on because the SQL Gateway returns a null session handle Martijn Visser (Jira)
• 2026/09/15 [jira] [Commented] (FLINK-39105) RestClientTest.testConnectionTimeout fails with different expected exception Martijn Visser (Jira)
• 2026/09/15 [jira] [Commented] (FLINK-40662) 'Run kubernetes Materialized Table test' fails on because the SQL Gateway returns a null session handle Martijn Visser (Jira)
• 2026/09/15 [jira] [Created] (FLINK-40670) MultiJoinSemanticTests[four-way-mixed-join-multi-key-types-shuffled] loses a row on release-2.3 Martijn Visser (Jira)
• 2026/09/15 Re: [PR] [hotfix] Correct author of the Kubernetes Operator 1.16.0 release announcement [flink-web] via GitHub
• 2026/09/15 [jira] [Created] (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/15 [jira] [Updated] (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/15 [jira] [Updated] (FLINK-40667) Buffer ref-count leaks in CDR recovery filtering end in free() on a live segment Rui Fan (Jira)
• 2026/09/15 Re: [PR] [FLINK-39997] Upgrade pemja to 0.6 [flink] via GitHub
• 2026/09/15 [jira] [Created] (FLINK-40668) Document why the recovery drain cannot stall on zero-credit needsRecovery channels Rui Fan (Jira)
• 2026/09/15 Re: [PR] [FLINK-40248][ci] Add nightly snapshot publishing to GHA pipeline [flink] via GitHub
• 2026/09/15 [jira] [Created] (FLINK-40667) Buffer ref-count leaks in CDR recovery filtering end in free() on a live segment Rui Fan (Jira)
• 2026/09/15 [jira] [Resolved] (FLINK-40520) Recovered channel-state spill files leak when recovery aborts between fetch and drain Rui Fan (Jira)
• 2026/09/15 Re: [PR] [integrations][java] Share POJO JSON Schema generation across Ollama, Gemini, Bedrock and watsonx [flink-agents] via GitHub
• 2026/09/15 [PR] [hotfix][cdc-composer] Fix "URI is not hierarchical" when resolving factory JAR path [flink-cdc] via GitHub
• 2026/09/15 [jira] [Created] (FLINK-40666) Simplify SNAPSHOT function by removing 'load_completed_condition' parameter Fabian Hueske (Jira)
• 2026/09/15 [jira] [Updated] (FLINK-40446) UnalignedCheckpointRescaleWithMixedExchangesITCase is unstable: @TempDir cleanup races with post-cancel async checkpoint Martijn Visser (Jira)
• 2026/09/15 Re: [PR] [FLINK-40665][ci] Use the Maven wrapper when deploying snapshot jars [flink] via GitHub
• 2026/09/15 [jira] [Updated] (FLINK-40446) UnalignedCheckpointRescaleWithMixedExchangesITCase is unstable: @TempDir cleanup races with post-cancel async checkpoint Martijn Visser (Jira)
• 2026/09/15 [jira] [Assigned] (FLINK-40665) cron_snapshot_deployment_maven fails the Maven version enforcer because deploy_staging_jars.sh uses the Maven on PATH Martijn Visser (Jira)
• 2026/09/15 Re: [PR] [api][runtime][python] Add opt-in Kafka tombstones for pruned action state [flink-agents] via GitHub
• 2026/09/15 Re: [PR] [FLINK-40136][Connectors/Kafka] Fix flaky ConcurrentModificationException in DynamicKafkaSourceEnumeratorTest [flink-connector-kafka] via GitHub
• 2026/09/15 Re: [PR] [FLINK-40139][Connectors/Kafka] Add default JUnit test timeout to fail hung tests fast [flink-connector-kafka] via GitHub
• 2026/09/15 Re: [PR] [runtime] Do not retry or persist interrupted tool calls on cancellation [flink-agents] via GitHub
• 2026/09/15 Re: [PR] [FLINK-40362][connector/kafka] Fix idle reader hang when no-more-splits precedes metadata update [flink-connector-kafka] via GitHub
• 2026/09/15 Re: [PR] [FLINK-40528][table-planner] Don't evaluate non-key expressions for partial delete StreamExecCalc [flink] via GitHub
• 2026/09/15 [PR] [FLINK-40665][ci] Use the Maven wrapper when deploying snapshot jars [flink] via GitHub
• 2026/09/15 [jira] [Updated] (FLINK-40665) cron_snapshot_deployment_maven fails the Maven version enforcer because deploy_staging_jars.sh uses the Maven on PATH ASF GitHub Bot (Jira)
• 2026/09/15 Re: [PR] Rebuild website [flink-web] via GitHub
• 2026/09/15 Re: [PR] [FLINK-40661][e2e] Build the test KDC image from debian:bookworm [flink] via GitHub
• 2026/09/15 Re: [PR] [FLINK-40661][e2e] Build the test KDC image from debian:bookworm [flink] via GitHub
• 2026/09/15 [PR] Rebuild website [flink-web] via GitHub
• 2026/09/15 [jira] [Closed] (FLINK-40528) Codegen should be tolerate to partial deletes Timo Walther (Jira)
• 2026/09/15 Re: [PR] [runtime] Do not retry or persist interrupted tool calls on cancellation [flink-agents] via GitHub
• 2026/09/15 Re: [PR] [runtime] Do not retry or persist interrupted tool calls on cancellation [flink-agents] via GitHub
• 2026/09/15 Re: [PR] [FLINK-40661][e2e] Build the test KDC image from debian:bookworm [flink] via GitHub
• 2026/09/15 [PR] [FLINK-40661][e2e] Build the test KDC image from debian:bookworm [flink] via GitHub
• 2026/09/15 [jira] [Updated] (FLINK-40661) Kerberized and PyFlink YARN Docker e2e tests fail on release-1.20 because the KDC image is built from debian:bullseye Martijn Visser (Jira)
• 2026/09/15 [jira] [Assigned] (FLINK-40661) Kerberized and PyFlink YARN Docker e2e tests fail on release-1.20 because the KDC image is built from debian:bullseye Martijn Visser (Jira)
• 2026/09/15 [jira] [Updated] (FLINK-40661) Kerberized and PyFlink YARN Docker e2e tests fail on release-1.20 because the KDC image is built from debian:bullseye ASF GitHub Bot (Jira)
• 2026/09/15 [jira] [Closed] (FLINK-40489) Add UUID_V4() & UUID_V7() functions Timo Walther (Jira)
• 2026/09/15 [PR] [FLINK-40661][e2e] Build the test KDC image from debian:bookworm [flink] via GitHub
• 2026/09/15 Re: [I] [Bug] Concurrent access to a shared PythonInterpreter can crash the JVM in async cross-language calls [flink-agents] via GitHub
• 2026/09/15 Re: [PR] [runtime][java] Make embedded Python interpreters thread-confined [flink-agents] via GitHub
• 2026/09/15 Re: [PR] [runtime][plan][python] Add built-in operational metrics [flink-agents] via GitHub
• 2026/09/15 Re: [PR] [api][plan][python] Expose sub-agents to chat models as callable tools [flink-agents] via GitHub
• 2026/09/15 Re: [PR] [FLINK-40489][table] Add UUID_V4() and UUID_V7() functions [flink] via GitHub
• 2026/09/15 [jira] [Commented] (FLINK-40648) PrometheusReporter drops all metrics of a process when two metric group variables sanitise to the same label name Efrat Levitan (Jira)
• 2026/09/15 [jira] [Updated] (FLINK-40528) Don't evaluate non-key expressions for partial delete StreamExecCalc Timo Walther (Jira)
• 2026/09/15 Re: [I] [Feature] Kafka ActionStateStore should clean up pruned ActionState records [flink-agents] via GitHub
• 2026/09/15 Re: [PR] Flink Kubernetes Operator 1.16.0 [flink-web] via GitHub
• 2026/09/15 [jira] [Reopened] (FLINK-40288) Multiple JoinSemanticTests fail Martijn Visser (Jira)
• 2026/09/15 [jira] [Commented] (FLINK-40493) VARIANT CAST for UUID (code 20) Sergey Nuyanzin (Jira)
• 2026/09/15 [jira] [Commented] (FLINK-39105) RestClientTest.testConnectionTimeout fails with different expected exception Martijn Visser (Jira)
• 2026/09/15 Re: [PR] [FLINK-40640][iceberg] Fix duplicate rows when an UPDATE changes the partition value [flink-cdc] via GitHub
• 2026/09/14 [jira] [Updated] (FLINK-40662) 'Run kubernetes Materialized Table test' fails on release-2.3 because the SQL Gateway returns a null session handle Martijn Visser (Jira)
• 2026/09/14 [jira] [Resolved] (FLINK-40493) VARIANT CAST for UUID (code 20) Sergey Nuyanzin (Jira)
• 2026/09/14 [jira] [Assigned] (FLINK-40493) VARIANT CAST for UUID (code 20) Sergey Nuyanzin (Jira)
• 2026/09/14 Re: [PR] [FLINK-40493][table] Support casting from VARIANT to UUID [flink] via GitHub
• 2026/09/14 Re: [PR] [integrations][java] Share POJO JSON Schema generation across Ollama, Gemini, Bedrock and watsonx [flink-agents] via GitHub
• 2026/09/14 [jira] [Commented] (FLINK-40571) ProcessTableFunctionSemanticTests[process-stateful-multi-input-with-timeout] is flaky on master Martijn Visser (Jira)
• 2026/09/14 [jira] [Commented] (FLINK-40288) Multiple JoinSemanticTests fail Martijn Visser (Jira)
• 2026/09/14 [jira] [Commented] (FLINK-38727) Unstable test cases EventTimeWindowCheckpointingITCase.testPreAggregatedSlidingTimeWindow Martijn Visser (Jira)
• 2026/09/14 [jira] [Reopened] (FLINK-39105) RestClientTest.testConnectionTimeout fails with different expected exception Martijn Visser (Jira)
• 2026/09/14 [jira] [Commented] (FLINK-40446) UnalignedCheckpointRescaleWithMixedExchangesITCase is unstable: @TempDir cleanup races with post-cancel async checkpoint Martijn Visser (Jira)
• 2026/09/14 [jira] [Created] (FLINK-40664) JobIDLoggingITCase.testJobIDLogging fails on a "Freeing inactive slots" log line without the job id Martijn Visser (Jira)
• 2026/09/14 [jira] [Created] (FLINK-40665) cron_snapshot_deployment_maven fails the Maven version enforcer because deploy_staging_jars.sh uses the Maven on PATH Martijn Visser (Jira)
• 2026/09/14 [jira] [Updated] (FLINK-40665) cron_snapshot_deployment_maven fails the Maven version enforcer because deploy_staging_jars.sh uses the Maven on PATH Martijn Visser (Jira)
• 2026/09/14 [jira] [Commented] (FLINK-35012) ChangelogNormalizeRestoreTest.testRestore failure Martijn Visser (Jira)
• 2026/09/14 [jira] [Created] (FLINK-40663) WindowDistinctAggregateStressITCase.testCumulateWindowRollupUnderBackpressure times out after 600s Martijn Visser (Jira)
• 2026/09/14 Re: [PR] [FLINK-40568][tests] Fix flaky ProcessTableFunctionSemanticTests by using materialized data assertion [flink] via GitHub
• 2026/09/14 [jira] [Updated] (FLINK-40661) Kerberized and PyFlink YARN Docker e2e tests fail on release-1.20 because the KDC image is built from debian:bullseye Martijn Visser (Jira)
• 2026/09/14 [jira] [Updated] (FLINK-40663) WindowDistinctAggregateStressITCase.testCumulateWindowRollupUnderBackpressure times out after 600s Martijn Visser (Jira)
• 2026/09/14 [jira] [Created] (FLINK-40662) 'Run kubernetes Materialized Table test' fails on release-2.3 because the SQL Gateway returns a null session handle Martijn Visser (Jira)
• 2026/09/14 [jira] [Created] (FLINK-40661) Kerberized and PyFlink YARN Docker e2e tests fail on release-1.20 because the KDC image is built from debian:bullseye Martijn Visser (Jira)
• 2026/09/14 Re: [PR] [api][plan][python][examples] Framework-managed LLM-as-judge routing (Strategies.llm) [flink-agents] via GitHub
• 2026/09/14 Re: [PR] [runtime] Cover the cross-loader action key failure and document action renaming [flink-agents] via GitHub
• 2026/09/14 Re: [I] [Bug] Pemja reference leaks in action execution and resource bridges [flink-agents] via GitHub
• 2026/09/14 Re: [PR] [runtime][python] Manage Pemja references across actions and resources [flink-agents] via GitHub
• 2026/09/14 [I] [Tech Debt][API][Python Bridge] Move concrete Python resource wrappers to the Plan module [flink-agents] via GitHub
• 2026/09/14 Re: [PR] [runtime] Do not retry or persist interrupted tool calls on cancellation [flink-agents] via GitHub
• 2026/09/14 [jira] [Closed] (FLINK-39986) Support Common Sub-Expression Elimination (CSE) for Python UDFs Dian Fu (Jira)
• 2026/09/14 Re: [PR] [FLINK-39986][table-planner][python] Support full-tree CSE for nested Python UDF calls [flink] via GitHub
• 2026/09/14 Re: [PR] [FLINK-40463][table] Widen JSON_VALUE and JSON_QUERY RETURNING type support [flink] via GitHub
• 2026/09/14 [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 Hongshun Wang (Jira)
• 2026/09/14 Re: [PR] [integrations][watsonx] List enum constants by their Jackson wire values [flink-agents] via GitHub
• 2026/09/14 [jira] [Assigned] (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 Hongshun Wang (Jira)
• 2026/09/14 Re: [PR] [integrations][watsonx] List enum constants by their Jackson wire values [flink-agents] via GitHub
• 2026/09/14 Re: [PR] [integrations][bedrock] Apply Bedrock native structured output [flink-agents] via GitHub
• 2026/09/14 [PR] [integrations][watsonx] List enum constants by their Jackson wire values [flink-agents] via GitHub
• 2026/09/14 Re: [I] [Bug][runtime] Durable action-state keys collide for distinct events with identical attributes [flink-agents] via GitHub
• 2026/09/14 Re: [PR] [integrations][watsonx] Support watsonx.ai native structured output [flink-agents] via GitHub
• 2026/09/14 Re: [PR] [FLINK-40655][runtime] Fix flaky partition release test [flink] via GitHub
• 2026/09/14 Re: [PR] [FLINK-40656][runtime] Reset schema coordinator state on checkpoint restore [flink-cdc] via GitHub
• 2026/09/14 [jira] [Commented] (FLINK-40658) UNNEST silently drops null ROW elements from ARRAY Bettle (Jira)
• 2026/09/14 [jira] [Updated] (FLINK-20746) Support ignore-first-line option for CSV format Leonard Xu (Jira)
• 2026/09/14 [jira] [Updated] (FLINK-20746) Support ignore-first-line option for CSV format Leonard Xu (Jira)
• 2026/09/14 [jira] [Resolved] (FLINK-20746) Support ignore-first-line option for CSV format Leonard Xu (Jira)
• 2026/09/14 Re: [PR] [integrations][bedrock] Apply Bedrock native structured output [flink-agents] via GitHub
• 2026/09/14 Re: [PR] [FLINK-20746][csv] Add csv.ignore-first-line for filesystem CSV connector [flink] via GitHub
• 2026/09/14 [jira] [Updated] (FLINK-40655) ExecutionVertexTest.testResetForNewExecutionReleasesPartitions is unstable ASF GitHub Bot (Jira)
• 2026/09/14 [PR] [FLINK-40655][runtime] Fix flaky partition release test [flink] via GitHub
• 2026/09/14 [jira] [Commented] (FLINK-40651) Support configurable Iceberg file rolling within a checkpoint Yanquan Lv (Jira)
• 2026/09/14 [jira] [Assigned] (FLINK-40651) Support configurable Iceberg file rolling within a checkpoint Yanquan Lv (Jira)
• 2026/09/14 Re: [PR] [runtime][plan][python] Add built-in operational metrics [flink-agents] via GitHub
• 2026/09/14 Re: [PR] [integrations][bedrock] Apply Bedrock native structured output [flink-agents] via GitHub
• 2026/09/14 Re: [PR] [integrations][bedrock] Apply Bedrock native structured output [flink-agents] via GitHub
• 2026/09/14 Re: [PR] [integrations][bedrock] Apply Bedrock native structured output [flink-agents] via GitHub
• 2026/09/14 [jira] [Closed] (FLINK-33772) Python e2e test fails with exit code 1 Dian Fu (Jira)
• 2026/09/14 [jira] [Closed] (FLINK-33706) Build_wheels_on_macos fails on AZP Dian Fu (Jira)
• 2026/09/14 [jira] [Closed] (FLINK-31802) Python py37-cython: commands failed, error at setup of ProcessWindowTests.test_count_sliding_window Dian Fu (Jira)
• 2026/09/14 [jira] [Closed] (FLINK-32604) PyFlink end-to-end fails with kafka-server-stop.sh: No such file or directory Dian Fu (Jira)
• 2026/09/14 [jira] [Closed] (FLINK-32151) 'Run kubernetes pyflink application test' fails while pulling image Dian Fu (Jira)
• 2026/09/14 [jira] [Comment Edited] (FLINK-40655) ExecutionVertexTest.testResetForNewExecutionReleasesPartitions is unstable Qiu Yanjun (Jira)
• 2026/09/14 [jira] [Commented] (FLINK-40655) ExecutionVertexTest.testResetForNewExecutionReleasesPartitions is unstable Qiu Yanjun (Jira)
• 2026/09/14 [jira] [Commented] (FLINK-38161) PyFlink: Unable to find Pemja library in thread mode when Python dependencies are installed in a separate layer Dian Fu (Jira)
• 2026/09/14 [jira] [Closed] (FLINK-38161) PyFlink: Unable to find Pemja library in thread mode when Python dependencies are installed in a separate layer Dian Fu (Jira)
• 2026/09/14 Re: [PR] [runtime][plan][python] Add built-in operational metrics [flink-agents] via GitHub
• 2026/09/14 Re: [PR] [integrations][gemini] Apply Gemini native structured output [flink-agents] via GitHub
• 2026/09/14 Re: [PR] [FLINK-39997] Upgrade pemja to 0.6 [flink] via GitHub
• 2026/09/14 Re: [PR] [FLINK-39997] Upgrade pemja to 0.6 [flink] via GitHub
• 2026/09/14 [jira] [Closed] (FLINK-37991) Upgrade pemja to 0.5.4 Dian Fu (Jira)
• 2026/09/14 [I] [Feature][runtime] Support parallel action execution on JDK < 21 [flink-agents] via GitHub
• 2026/09/14 [jira] [Commented] (FLINK-40419) Add regular join support to DataFrame API Dian Fu (Jira)
• 2026/09/14 [jira] [Assigned] (FLINK-40419) Add regular join support to DataFrame API Dian Fu (Jira)
• 2026/09/14 Re: [PR] [FLINK-38835][postgres] Fix timestamp conversion to LocalDateTime for dates before 1970-01-01. [flink-cdc] via GitHub
• 2026/09/14 Re: [PR] [FLINK-38835][postgres] Fix timestamp conversion to LocalDateTime for dates before 1970-01-01. [flink-cdc] via GitHub
• 2026/09/14 [jira] [Commented] (FLINK-40446) UnalignedCheckpointRescaleWithMixedExchangesITCase is unstable: @TempDir cleanup races with post-cancel async checkpoint Rui Fan (Jira)
• 2026/09/14 [jira] [Commented] (FLINK-40446) UnalignedCheckpointRescaleWithMixedExchangesITCase is unstable: @TempDir cleanup races with post-cancel async checkpoint Rui Fan (Jira)
• 2026/09/14 [jira] [Updated] (FLINK-40446) UnalignedCheckpointRescaleWithMixedExchangesITCase is unstable: @TempDir cleanup races with post-cancel async checkpoint Rui Fan (Jira)
• 2026/09/14 Re: [PR] [runtime] Cover the cross-loader action key failure and document action renaming [flink-agents] via GitHub
• 2026/09/14 Re: [PR] [runtime] Cover the cross-loader action key failure and document action renaming [flink-agents] via GitHub
• 2026/09/14 Re: [PR] [api][plan][python][examples] Framework-managed LLM-as-judge routing (Strategies.llm) [flink-agents] via GitHub
• 2026/09/14 [jira] [Updated] (FLINK-40660) SplitFetcher hangs on shutdown when its element queue wakeUp flag is still set ASF GitHub Bot (Jira)
• 2026/09/14 Re: [PR] [FLINK-40601][runtime-web] Add Vitest specs for remaining web dashboard views [flink] via GitHub
• 2026/09/14 Re: [PR] [FLINK-40660][connector-base] Retry the shutdown synchronization put in SplitFetcher [flink] via GitHub
• 2026/09/14 Re: [PR] [FLINK-40576][fs] Exclude transitive alluxio dependency from flink-s3-fs-presto [flink] via GitHub
• 2026/09/14 [PR] [FLINK-40660][connector-base] Retry the shutdown synchronization put in SplitFetcher [flink] via GitHub
• 2026/09/14 [jira] [Closed] (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/14 Re: [PR] [FLINK-40467] Randomise application result store paths [flink-kubernetes-operator] via GitHub
• 2026/09/14 Re: [PR] [FLINK-38592] Initial Native Flink S3 FileSystem [flink] via GitHub
• 2026/09/14 [jira] [Closed] (FLINK-40550) Kubernetes Operator: documented reconcile.parallelism: -1 crashes operator at startup Gyula Fora (Jira)
• 2026/09/14 [jira] [Assigned] (FLINK-40550) Kubernetes Operator: documented reconcile.parallelism: -1 crashes operator at startup Gyula Fora (Jira)
• 2026/09/14 Re: [PR] [FLINK-40550] Fix operator crash when reconcile.parallelism is -1 [flink-kubernetes-operator] via GitHub
• 2026/09/14 Re: [PR] [FLINK-40550] Fix operator crash when reconcile.parallelism is -1 [flink-kubernetes-operator] via GitHub
• 2026/09/14 [jira] [Created] (FLINK-40655) ExecutionVertexTest.testResetForNewExecutionReleasesPartitions is unstable Martijn Visser (Jira)
• 2026/09/14 Re: [PR] [FLINK-40467] Randomise application result store paths [flink-kubernetes-operator] via GitHub
• 2026/09/14 [jira] [Commented] (FLINK-40657) FutureCompletingBlockingQueue retains a ConditionAndFlag for every SplitFetcher ever created Alexandru (Jira)
• 2026/09/14 [jira] [Assigned] (FLINK-40472) Add Arrow-native vectorized UDF support to DataFrame API Dian Fu (Jira)
• 2026/09/14 Re: [PR] [FLINK-40587] Recreating a FlinkDeployment throws an autoscaler exception [flink-kubernetes-operator] via GitHub
• 2026/09/14 Re: [PR] [FLINK-40583] Filter operator keys on the remaining runtime config paths [flink-kubernetes-operator] via GitHub
• 2026/09/14 [jira] [Created] (FLINK-40651) Support configurable Iceberg file rolling within a checkpoint Yanquan Lv (Jira)
• 2026/09/14 [jira] [Updated] (FLINK-40660) SplitFetcher hangs on shutdown when its element queue wakeUp flag is still set Martijn Visser (Jira)
• 2026/09/14 [jira] [Created] (FLINK-40659) SingleThreadFetcherManager reaps and recreates its fetcher on every idle gap Martijn Visser (Jira)
• 2026/09/14 [jira] [Created] (FLINK-40660) SplitFetcher hangs on shutdown when its element queue wakeUp flag is still set Martijn Visser (Jira)
• 2026/09/14 Re: [PR] [FLINK-40652][tests] Pull MinIO from quay.io instead of the removed Docker Hub repository [flink] via GitHub
• 2026/09/14 [jira] [Commented] (FLINK-40657) FutureCompletingBlockingQueue retains a ConditionAndFlag for every SplitFetcher ever created Martijn Visser (Jira)
• 2026/09/14 Re: [PR] [hotfix] Fix E2E tests [flink-kubernetes-operator] via GitHub
• 2026/09/14 Re: [PR] [FLINK-39697] Support Flink 2.0.x and Pulsar Client 4.0.9 [flink-connector-pulsar] via GitHub
• 2026/09/14 Re: [PR] [FLINK-38592] Initial Native Flink S3 FileSystem [flink] via GitHub
• 2026/09/14 [jira] [Comment Edited] (FLINK-40653) Testcontainers tests fail with "Could not find a valid Docker environment" on the cron_azure profile Martijn Visser (Jira)
• 2026/09/14 [jira] [Resolved] (FLINK-40653) Testcontainers tests fail with "Could not find a valid Docker environment" on the cron_azure profile Martijn Visser (Jira)
• 2026/09/14 Re: [PR] [FLINK-40653][ci] Map the Docker socket into job containers [flink] via GitHub
• 2026/09/14 Re: [PR] [FLINK-40653][ci] Map the Docker socket into job containers [flink] via GitHub
• 2026/09/14 Re: [PR] [FLINK-40653][ci] Map the Docker socket into job containers [flink] via GitHub
• 2026/09/14 Re: [PR] [FLINK-40653][ci] Map the Docker socket into job containers [flink] via GitHub
• 2026/09/14 Re: [PR] [FLINK-40653][ci] Map the Docker socket into job containers [flink] via GitHub
• 2026/09/14 Re: [PR] [FLINK-40653][ci] Map the Docker socket into job containers [flink] via GitHub
• 2026/09/14 Re: [PR] [FLINK-20746][csv] Add csv.ignore-first-line for filesystem CSV connector [flink] via GitHub
• 2026/09/14 [jira] [Updated] (FLINK-40656) Distributed schema coordinator can remain EVOLVING after checkpoint restore Xiaobing Fang (Jira)
• 2026/09/14 [jira] [Created] (FLINK-40658) UNNEST silently drops null ROW elements from ARRAY Bettle (Jira)
• 2026/09/14 Re: [PR] [FLINK-39697] Support Flink 2.0.x and Pulsar Client 4.0.9 [flink-connector-pulsar] via GitHub
• 2026/09/14 Re: [PR] [FLINK-38262][table] show create connection operation [flink] via GitHub
• 2026/09/14 [jira] [Commented] (FLINK-40651) Support configurable Iceberg file rolling within a checkpoint VISHAL B (Jira)
• 2026/09/14 Re: [PR] [FLINK-39697] Support Flink 2.0.x and Pulsar Client 4.0.9 [flink-connector-pulsar] via GitHub
• 2026/09/14 Re: [PR] [FLINK-40493][table] Support casting from VARIANT to UUID [flink] via GitHub
• 2026/09/14 [jira] [Commented] (FLINK-40419) Add regular join support to DataFrame API FangHao (Jira)
• 2026/09/14 Re: [PR] [FLINK-38262][table] show create connection operation [flink] via GitHub
• 2026/09/14 Re: [PR] [FLINK-38262][table] show create connection operation [flink] via GitHub
• 2026/09/14 Re: [PR] [FLINK-38262][table] show create connection operation [flink] via GitHub
• 2026/09/14 Re: [PR] [FLINK-40652][tests] Pull MinIO from quay.io instead of the removed Docker Hub repository [flink] via GitHub
• 2026/09/14 [jira] [Resolved] (FLINK-40633) Make download-crt-jars.sh maven command agnostic Gabor Somogyi (Jira)
• 2026/09/14 [jira] [Closed] (FLINK-40633) Make download-crt-jars.sh maven command agnostic Gabor Somogyi (Jira)
• 2026/09/14 [jira] [Commented] (FLINK-40633) Make download-crt-jars.sh maven command agnostic Gabor Somogyi (Jira)

• Earlier messages
• Later messages