dev  

Messages by Date

• 2026/09/26 [jira] [Created] (FLINK-40820) Remove the fallback configuration keys from the flink-s3-fs-base module. Yuepeng Pan (Jira)
• 2026/09/26 [jira] [Created] (FLINK-40822) Bump maven-compiler-plugin to 3.16.0 Sergey Nuyanzin (Jira)
• 2026/09/26 [jira] [Created] (FLINK-40821) Remove the fallback configuration keys from the flink-avro-confluent-registry module. Yuepeng Pan (Jira)
• 2026/09/26 [jira] [Created] (FLINK-40813) Remove the deprecated configuration keys from the flink-clients module. Yuepeng Pan (Jira)
• 2026/09/26 [jira] [Created] (FLINK-40819) Remove the fallback configuration keys from the flink-kubernetes module. Yuepeng Pan (Jira)
• 2026/09/26 [jira] [Created] (FLINK-40818) Remove the fallback configuration keys from the flink-core module. Yuepeng Pan (Jira)
• 2026/09/26 [jira] [Created] (FLINK-40817) Remove the deprecated configuration keys from the flink-yarn module. Yuepeng Pan (Jira)
• 2026/09/26 [jira] [Created] (FLINK-40816) Remove the deprecated configuration keys from the flink-kubernetes module. Yuepeng Pan (Jira)
• 2026/09/26 [jira] [Created] (FLINK-40814) Remove the deprecated configuration keys from the flink-core module. Yuepeng Pan (Jira)
• 2026/09/26 [jira] [Created] (FLINK-40815) Remove the deprecated configuration keys from the flink-dstl-dfs module. Yuepeng Pan (Jira)
• 2026/09/26 [jira] [Created] (FLINK-40812) [Backport][1.20] Backport FLINK-38558 to release-1.20 lazykitty (Jira)
• 2026/09/26 Re: [DISCUSS] FLIP-614: Add built-in DEDUPLICATE_KEEP_FIRST PTF Roman Khachatryan
• 2026/09/25 Re: [DISCUSS] FLINK-40234: which layer should stop busy subtask time from marking source splits idle? Roman Khachatryan
• 2026/09/25 [jira] [Created] (FLINK-40811) Verify the nightlies host key in the docs upload Martijn Visser (Jira)
• 2026/09/25 [jira] [Created] (FLINK-40810) FlinkSessionJob deletion leaves the job running when a transient Job Not Found error was never cleared Han You (Jira)
• 2026/09/25 [jira] [Created] (FLINK-40809) Regular outer join loses the null-padded row when an input record is updated without UPDATE_BEFORE Gustavo de Morais (Jira)
• 2026/09/25 [jira] [Created] (FLINK-40808) Setting up PyPI for AWS Connector Ryan Pelaez (Jira)
• 2026/09/25 [DISCUSS] FLIP-614: Add built-in DEDUPLICATE_KEEP_FIRST PTF Vas Shabu
• 2026/09/25 Re: [VOTE] FLIP-612: Native XML Functions for Flink SQL Krishna Sai
• 2026/09/25 [jira] [Created] (FLINK-40807) Add XML_STRING() function Moritz Manner (Jira)
• 2026/09/25 [jira] [Created] (FLINK-40806) Add PARSE_XML() and TRY_PARSE_XML() functions Moritz Manner (Jira)
• 2026/09/25 [jira] [Created] (FLINK-40805) FLIP-612: Native XML Functions for Flink SQL Moritz Manner (Jira)
• 2026/09/25 Re: [VOTE] FLIP-612: Native XML Functions for Flink SQL Gustavo de Morais
• 2026/09/25 Re: [VOTE] FLIP-612: Native XML Functions for Flink SQL Sergey Nuyanzin
• 2026/09/25 [VOTE] FLIP-612: Native XML Functions for Flink SQL Moritz Manner
• 2026/09/25 Re: [DISCUSS] FLIP-612: Native XML Functions for Flink SQL Timo Walther
• 2026/09/25 [jira] [Created] (FLINK-40804) UnalignedCheckpointRescaleWithMixedExchangesITCase.testRescaleFromUnalignedCheckpoint fails with "Exceeded checkpoint tolerable failure threshold" Martijn Visser (Jira)
• 2026/09/25 [jira] [Created] (FLINK-40803) "Build documentation" fails with startup_failure because the burnett01/rsync-deployments 8.0.5 pin expired Martijn Visser (Jira)
• 2026/09/25 [jira] [Created] (FLINK-40802) MinioTestContainerTest and the S3 e2e tests fail on all release branches because quay.io/minio/minio is no longer public Martijn Visser (Jira)
• 2026/09/25 [jira] [Created] (FLINK-40801) Enable TLS 1.3 in default SSL protocol and cipher suites Gabor Somogyi (Jira)
• 2026/09/25 [jira] [Created] (FLINK-40800) When scaling in Flink is performed Autoscaler decision is not applied anymore Sergey Kononov (Jira)
• 2026/09/24 [jira] [Created] (FLINK-40799) ClassCastException in FlinkMarkChangelogNormalizeProgram when an upsert source is read twice with the same boolean column filter Chris Johnson (Jira)
• 2026/09/24 [jira] [Created] (FLINK-40798) Move partial INSERT off the source rewrite in PreValidateReWriter Martijn Visser (Jira)
• 2026/09/24 [jira] [Created] (FLINK-40797) Exclude NestedLoopJoin from CBO search space when an equi-join condition exists and another equi-capable strategy is applicable Bonnie Varghese (Jira)
• 2026/09/24 [jira] [Created] (FLINK-40796) State processor API no longer rejects key types that cannot be hashed reliably sepuri sai krishna (Jira)
• 2026/09/24 [jira] [Created] (FLINK-40795) Re-added table with drifted schema is silently skipped: downstream table not re-created and stale schema state causes write failures peiyu (Jira)
• 2026/09/24 Re: [DISCUSS] FLIP-612: Native XML Functions for Flink SQL Moritz Manner
• 2026/09/24 [jira] [Created] (FLINK-40794) CAST in Table API ignores input nullability when the target type is NOT NULL Ramin Gharib (Jira)
• 2026/09/24 [jira] [Created] (FLINK-40793) DefaultSchedulerTest is unstable across many test methods sepuri sai krishna (Jira)
• 2026/09/24 Re: [DISCUSS] Declarative Error Handling in Flink SQL via ON ERROR Clause Dale Lane via dev
• 2026/09/24 Re: [DISCUSS][FLINK-40574] Upgrade SLF4J from 1.7 to 2.x P Sinha
• 2026/09/24 [DISCUSS][FLINK-40574] Upgrade SLF4J from 1.7 to 2.x Piotr Przybylski
• 2026/09/24 [jira] [Created] (FLINK-40792) Emit "Z" instead of "+00:00" for UTC in Variant.toJson() Ramin Gharib (Jira)
• 2026/09/24 [jira] [Created] (FLINK-40788) 'Heavy deployment end-to-end test' fails because all TaskManagers run out of memory on Java 11 Martijn Visser (Jira)
• 2026/09/24 [jira] [Created] (FLINK-40790) DefaultDeclarativeSlotPoolTest.testIncreasingResourceRequirementsWillSendResourceRequirementNotification receives the first increment alone Martijn Visser (Jira)
• 2026/09/24 [jira] [Created] (FLINK-40791) OpenTelemetryMetricReporterITCase.testCounterDelta fails with expected 1234 but was 25 Martijn Visser (Jira)
• 2026/09/24 [jira] [Created] (FLINK-40789) RescaleTimelineITCase.testRecordRescaleForNewAvailableResource records three rescales instead of two Martijn Visser (Jira)
• 2026/09/24 [jira] [Created] (FLINK-40787) 'Flink CLI end-to-end test' fails with "Unexpected task manager slot count" Martijn Visser (Jira)
• 2026/09/24 [jira] [Created] (FLINK-40786) compile_cron_azure fails with OutOfMemoryError in japicmp on flink-s3-fs-presto Martijn Visser (Jira)
• 2026/09/24 [jira] [Created] (FLINK-40785) Nightly snapshot deployment fails in spotless because google-java-format 1.28.0 does not run on JDK 11 Martijn Visser (Jira)
• 2026/09/24 [DISCUSS] Clarifying the checkpoint upload path and performance attribution in the Native S3 benchmark Xia Rui
• 2026/09/24 Re: [DISCUSS] Emit "Z" instead of "+00:00" for UTC in Variant.toJson() Ramin Gharib
• 2026/09/23 Re: [DISCUSS] FLINK-32806 - EmbeddedJobResultStore retains clean job result entries forever Matthias Pohl
• 2026/09/23 [DISCUSS] FLINK-32806 - EmbeddedJobResultStore retains clean job result entries forever L L
• 2026/09/23 [jira] [Created] (FLINK-40784) Upgrade ArchUnit to 1.5.0 in flink-connector-kafka Purushottam Sinha (Jira)
• 2026/09/23 [jira] [Created] (FLINK-40783) Upgrade HikariCP from 4.0.3 to 7.1.0 peiyu (Jira)
• 2026/09/23 [jira] [Created] (FLINK-40782) Fail connector CI when ArchUnit would update a frozen violation store Martijn Visser (Jira)
• 2026/09/23 [jira] [Created] (FLINK-40781) ArchUnit tests in flink-connector-jdbc don't analyse any production classes Martijn Visser (Jira)
• 2026/09/23 Re: [DISCUSS] FLIP-XXX: GEOGRAPHY type in Flink SQL and Table API David Chaava via dev
• 2026/09/23 [jira] [Created] (FLINK-40780) FORWARD edge silently converted to REBALANCE on parallelism mismatch corrupts changelog (upsert/retract) streams Rui Fan (Jira)
• 2026/09/23 [jira] [Created] (FLINK-40779) JdbcSourceEnumerator snapshots splitter state ahead of the splits it has handled Martijn Visser (Jira)
• 2026/09/23 [jira] [Created] (FLINK-40778) JdbcTablePlanTest.testFilterPushdown fails against Flink 2.4 because of the upper-case AND in the filter digest Martijn Visser (Jira)
• 2026/09/23 Re: [VOTE] FLIP-611: Running Flink jobs in MiniCluster using the Kubernetes Operator Dale Lane via dev
• 2026/09/23 [jira] [Created] (FLINK-40777) Run the XA connection tests against PostgreSQL Martijn Visser (Jira)
• 2026/09/23 [ANNOUNCE] Apache Flink Kubernetes Operator 1.16.1 released Gyula Fóra
• 2026/09/22 [jira] [Created] (FLINK-40776) PARSE_URL compiles the query-parameter pattern on every row Utkarsh Vashishtha (Jira)
• 2026/09/22 Re: [DISCUSS] Emit "Z" instead of "+00:00" for UTC in Variant.toJson() Krishna Sai
• 2026/09/22 [PR] [FLINK-40775][ci] Add a PR template with AI disclosure [flink-ci-docker] via GitHub
• 2026/09/22 [jira] [Created] (FLINK-40774) Add a PR template with AI disclosure for flink-jira-bot Aleksandr Savonin (Jira)
• 2026/09/22 [jira] [Created] (FLINK-40773) Add a PR template with AI disclosure for flink-playgrounds Aleksandr Savonin (Jira)
• 2026/09/22 [jira] [Created] (FLINK-40775) Add a PR template with AI disclosure for flink-ci-docker Aleksandr Savonin (Jira)
• 2026/09/22 [jira] [Created] (FLINK-40772) Add a PR template with AI disclosure for flink-training Aleksandr Savonin (Jira)
• 2026/09/22 [jira] [Created] (FLINK-40771) Add a PR template with AI disclosure for flink-connector-redis-streams Aleksandr Savonin (Jira)
• 2026/09/22 [jira] [Created] (FLINK-40770) Add a PR template with AI disclosure for flink-connector-rabbitmq Aleksandr Savonin (Jira)
• 2026/09/22 [jira] [Created] (FLINK-40769) Add a PR template with AI disclosure for flink-connector-gcp-pubsub Aleksandr Savonin (Jira)
• 2026/09/22 [jira] [Created] (FLINK-40768) Add a PR template with AI disclosure for flink-connector-cassandra Aleksandr Savonin (Jira)
• 2026/09/22 Re: [DISCUSS] Emit "Z" instead of "+00:00" for UTC in Variant.toJson() Timo Walther
• 2026/09/22 [jira] [Created] (FLINK-40767) Add a PR template with AI disclosure for flink-connector-hbase Aleksandr Savonin (Jira)
• 2026/09/22 [jira] [Created] (FLINK-40766) Add AI disclosure to the flink-ml PR template Aleksandr Savonin (Jira)
• 2026/09/22 [jira] [Created] (FLINK-40765) Add a PR template with AI disclosure for flink-agents-demos Aleksandr Savonin (Jira)
• 2026/09/22 [jira] [Created] (FLINK-40764) Add a PR template with AI disclosure for flink-benchmarks Aleksandr Savonin (Jira)
• 2026/09/22 [jira] [Created] (FLINK-40763) Add a PR template with AI disclosure for flink-connector-kudu Aleksandr Savonin (Jira)
• 2026/09/22 [jira] [Created] (FLINK-40762) Add a PR template with AI disclosure for flink-connector-hive Aleksandr Savonin (Jira)
• 2026/09/22 [jira] [Created] (FLINK-40761) Add AI disclosure to the flink-connector-prometheus PR template Aleksandr Savonin (Jira)
• 2026/09/22 [jira] [Created] (FLINK-40760) Add AI disclosure to the flink-connector-pulsar PR template Aleksandr Savonin (Jira)
• 2026/09/22 [DISCUSS] Emit "Z" instead of "+00:00" for UTC in Variant.toJson() Ramin Gharib
• 2026/09/22 Re: [VOTE] Apache Flink Kubernetes Operator Release 1.16.1, release candidate #1 Gyula Fóra
• 2026/09/22 [jira] [Created] (FLINK-40759) Add a PR template with AI disclosure for flink-connector-shared-utils Aleksandr Savonin (Jira)
• 2026/09/22 [jira] [Created] (FLINK-40758) Add a PR template with AI disclosure for flink-connector-http Aleksandr Savonin (Jira)
• 2026/09/22 [jira] [Created] (FLINK-40756) Add a PR template with AI disclosure for flink-shaded Aleksandr Savonin (Jira)
• 2026/09/22 [jira] [Created] (FLINK-40757) Add a PR template with AI disclosure for flink-connector-elasticsearch Aleksandr Savonin (Jira)
• 2026/09/22 [jira] [Created] (FLINK-40755) Add a PR template with AI disclosure for flink-web Aleksandr Savonin (Jira)
• 2026/09/22 [jira] [Created] (FLINK-40754) Add a PR template with AI disclosure for flink-docker Aleksandr Savonin (Jira)
• 2026/09/22 [jira] [Created] (FLINK-40753) Correlated subqueries over SQL VALUES fail during decorrelation FangHao (Jira)
• 2026/09/22 [jira] [Created] (FLINK-40748) PreparedSplitterNumericParameters.withBatchSize reads past maxVal Martijn Visser (Jira)
• 2026/09/22 [jira] [Created] (FLINK-40752) Add a PR template with AI disclosure for flink-connector-opensearch Aleksandr Savonin (Jira)
• 2026/09/22 Re: [DISCUSS] FLIP-612: Native XML Functions for Flink SQL Timo Walther
• 2026/09/22 [jira] [Created] (FLINK-40751) State Processor environment and operators should use task memory/io manager Gyula Fora (Jira)
• 2026/09/22 [jira] [Created] (FLINK-40750) Add AI disclosure to the Flink AWS connectors PR template Aleksandr Savonin (Jira)
• 2026/09/22 [jira] [Created] (FLINK-40749) Add or update PR templates with AI disclosure across Flink repositories Aleksandr Savonin (Jira)
• 2026/09/22 [RESULT] [VOTE] Apache Flink Kubernetes Operator Release 1.16.1, release candidate #1 Gyula Fóra
• 2026/09/22 [jira] [Created] (FLINK-40745) PyFlink JDBC sink binds to classes that no longer exist in flink-connector-jdbc 4.x Martijn Visser (Jira)
• 2026/09/22 [jira] [Created] (FLINK-40740) Fluss source can assign the same splits more than once during periodic discovery Xiaobing Fang (Jira)
• 2026/09/22 [jira] [Created] (FLINK-40737) COLLECT over a non-time OVER window returns only the current row instead of the running window sepuri sai krishna (Jira)
• 2026/09/22 [jira] [Created] (FLINK-40742) Pin the JDBC Table sink's changelog behaviour with tests before the Sink V2 migration Martijn Visser (Jira)
• 2026/09/22 [jira] [Created] (FLINK-40744) Remove the dead InputFormat and OutputFormat classes from flink-connector-jdbc Martijn Visser (Jira)
• 2026/09/22 [jira] [Created] (FLINK-40747) PreparedSplitterEnumerator.of(sqlTemplate) produces no split, the source reads nothing Martijn Visser (Jira)
• 2026/09/22 [jira] [Created] (FLINK-40746) Deprecate the JdbcSourceBuilder setters that only the deprecated setSql path reads Martijn Visser (Jira)
• 2026/09/22 [jira] [Created] (FLINK-40743) JDBC Table sink reports an empty lineage dataset name Martijn Visser (Jira)
• 2026/09/22 [jira] [Created] (FLINK-40741) [Flink cdc]After the full snapshot read of the newly added table completes, the newly added table is no longer synchronized, while the existing (old) tables continue reading Ruan Hang (Jira)
• 2026/09/22 [jira] [Created] (FLINK-40739) [Bug][pipeline-connector][maxcompute] Partition values extracted from wrong column index when partition columns are not contiguous at the end of schema Yanquan Lv (Jira)
• 2026/09/22 [jira] [Created] (FLINK-40734) [Umbrella] Remove Deprecated Configuration Options/Keys in Flink Yuepeng Pan (Jira)
• 2026/09/22 Re: [DISCUSS] FLIP-612: Native XML Functions for Flink SQL Krishna Sai
• 2026/09/22 [jira] [Created] (FLINK-40735) OVER window ordered by a non-time attribute fails for LAG and ARRAY_AGG when a row arrives out of order sepuri sai krishna (Jira)
• 2026/09/21 [jira] [Created] (FLINK-40738) LAG/LEAD with a non-null default value returns the default instead of NULL sepuri sai krishna (Jira)
• 2026/09/21 [jira] [Created] (FLINK-40736) Non-time ROWS OVER window emits a malformed row for FIRST_VALUE, LAST_VALUE, LISTAGG, COUNT(DISTINCT), ARRAY_AGG, COLLECT and PERCENTILE sepuri sai krishna (Jira)
• 2026/09/21 [jira] [Created] (FLINK-40733) Trino tests are disabled, so the Trino dialect has no test coverage Martijn Visser (Jira)
• 2026/09/21 [jira] [Created] (FLINK-40727) Support comma-separated security.ssl.protocol and fix internal SSL hostname verification regression Gabor Somogyi (Jira)
• 2026/09/21 [jira] [Created] (FLINK-40732) Release finished snapshot split metadata in the MongoDB CDC connector Spoorthi Basu (Jira)
• 2026/09/21 Re: [VOTE] FLIP-569: Sunset the Stateful Functions (StateFun) Sub-project Zakelly Lan
• 2026/09/21 [jira] [Created] (FLINK-40728) [FLIP-607] Migrate Flink off end-of-life OkHttp; keep it off the core classpath Martijn Visser (Jira)
• 2026/09/21 [jira] [Created] (FLINK-40731) CONVERT_TZ silently returns a wrong timestamp for a time zone it does not recognize sepuri sai krishna (Jira)
• 2026/09/21 Re: [DISCUSS] FLIP-612: Native XML Functions for Flink SQL Moritz Manner
• 2026/09/21 [jira] [Created] (FLINK-40729) Refresh the JDBC driver and test dependency versions raised by Dependabot Martijn Visser (Jira)
• 2026/09/21 [jira] [Created] (FLINK-40730) Remove the Derby dialect now that Derby is retired and replace it with H2 Martijn Visser (Jira)
• 2026/09/21 Review request: FLINK-40574 (Update SLF4J from 1.7.36 to 2.x) - PR #29120 Piotr Przybylski
• 2026/09/21 [RESULT][VOTE] FLIP-607: Migrate Flink off end-of-life OkHttp; keep it off the core classpath Martijn Visser
• 2026/09/21 Re: [VOTE] FLIP-607: Migrate Flink off end-of-life OkHttp; keep it off the core classpath Martijn Visser
• 2026/09/21 Re: [VOTE] FLIP-611: Running Flink jobs in MiniCluster using the Kubernetes Operator Robert Metzger
• 2026/09/21 Re: [VOTE] Apache Flink Kubernetes Operator Release 1.16.1, release candidate #1 Gyula Fóra
• 2026/09/21 [jira] [Created] (FLINK-40726) Reading a key from a map returned by MAP_FROM_ARRAYS / MAP_FROM_ENTRIES / MAP_UNION fails with ClassCastException sepuri sai krishna (Jira)
• 2026/09/21 Re: [VOTE] Apache Flink Kubernetes Operator Release 1.16.1, release candidate #1 Robert Metzger
• 2026/09/20 Swag request from a high school student who loves Apache Flink Anshumaan Vyas
• 2026/09/20 [jira] [Created] (FLINK-40725) JDBC table sink incompatible with Flink 2.3.0 ON CONFLICT / upsert-key validation Purushottam Sinha (Jira)
• 2026/09/20 [jira] [Created] (FLINK-40724) Add maven wrapper to connectors Sergey Nuyanzin (Jira)
• 2026/09/20 [jira] [Created] (FLINK-40723) Test JDK 21 and current Flink minor lines in CI Purushottam Sinha (Jira)
• 2026/09/20 [jira] [Created] (FLINK-40722) Create AGENTS.md for Flink JDBC connector and update the PR description to track AI usage Purushottam Sinha (Jira)
• 2026/09/20 [SUMMARY] Flink 2.4 Release Sync - 18.09.26 Sumin Joo
• 2026/09/20 Re: [PR] [FLINK-40721][ci] Add maven 3.9.16 to ci docker [flink-ci-docker] via GitHub
• 2026/09/19 Re: [PR] [FLINK-40721][ci] Add maven 3.9.16 to ci docker [flink-ci-docker] via GitHub
• 2026/09/19 [PR] [FLINK-40721][ci] Add maven 3.9.16 to ci docker [flink-ci-docker] via GitHub
• 2026/09/19 [jira] [Created] (FLINK-40721) Add maven 3.9.16 to ci docker Sergey Nuyanzin (Jira)
• 2026/09/19 [jira] [Created] (FLINK-40720) Do not checkout all branches in ci Sergey Nuyanzin (Jira)
• 2026/09/19 [jira] [Created] (FLINK-40719) Free disk space silently fails with E: Unable to locate package hhvm Sergey Nuyanzin (Jira)
• 2026/09/19 [jira] [Created] (FLINK-40717) Create AGENTS.md for Flink MongoDB connector and update the PR description to track AI usage Purushottam Sinha (Jira)
• 2026/09/19 [jira] [Created] (FLINK-40718) Do not run weekly if there is no new commits since the last green run Purushottam Sinha (Jira)
• 2026/09/19 Re: [VOTE] FLIP-569: Sunset the Stateful Functions (StateFun) Sub-project P Sinha
• 2026/09/19 [jira] [Created] (FLINK-40716) [FileSystem] common filesystems interfaces for hadoop-less implementations Aleksandr Iushmanov (Jira)
• 2026/09/19 [jira] [Created] (FLINK-40715) FLIP-597 [FileSystems] Support common implementation for SDK native hadoop-less file systems Aleksandr Iushmanov (Jira)
• 2026/09/19 [jira] [Created] (FLINK-40713) Bump mongo-driver version from 5.1.1 to 5.11.1 to fix CVE-2026-88033 Purushottam Sinha (Jira)
• 2026/09/19 [jira] [Created] (FLINK-40712) Update dependencies in the Flink Connector MongoDB Project Purushottam Sinha (Jira)
• 2026/09/19 [jira] [Created] (FLINK-40714) Add MongoDB 8.0 to the multi-version integration test matrix Purushottam Sinha (Jira)
• 2026/09/18 [jira] [Created] (FLINK-40711) Don not run weekly if there is no new commits since the last green runs Sergey Nuyanzin (Jira)
• 2026/09/18 [jira] [Created] (FLINK-40710) Dynamic Kafka Source assigns duplicate partition owners after local failover Bowen Li (Jira)
• 2026/09/18 [jira] [Created] (FLINK-40709) Kubernetes Operator: allowlist to exempt trusted hosts from jarURI restricted-host check Purushottam Sinha (Jira)
• 2026/09/18 [jira] [Created] (FLINK-40707) Backports of FLINK-39572 breaks previous releases because of different Beam version Martijn Visser (Jira)
• 2026/09/18 Re: [VOTE] Apache Flink Kubernetes Operator Release 1.16.1, release candidate #1 Rui Fan
• 2026/09/18 [jira] [Created] (FLINK-40708) Support ValueView in PTFs Timo Walther (Jira)
• 2026/09/18 Re: [VOTE] Apache Flink Kubernetes Operator Release 1.16.1, release candidate #1 Dennis-Mircea Ciupitu
• 2026/09/18 Re: [DISCUSS] FLIP-612: Native XML Functions for Flink SQL Timo Walther
• 2026/09/18 Re: [DISCUSS] FLIP-612: Native XML Functions for Flink SQL Fabian Hüske via dev
• 2026/09/17 [jira] [Created] (FLINK-40706) Harden address validation in kubernetes operator artifact fetcher Purushottam Sinha (Jira)
• 2026/09/17 Re: [DISCUSS] FLIP-XXXX: Higher-Order Functions in Flink SQL (TRANSFORM and ARRAY_FILTER) Dominik.Buenzli
• 2026/09/17 [jira] [Created] (FLINK-40705) PyFlink pandas UDFs fail on MAP inputs across Arrow batches Liu Liu (Jira)
• 2026/09/17 [DISCUSS] FLIP-608: Flink on Ray, Ray Resource Backend For Flink Zhanghao Chen
• 2026/09/17 Re: [VOTE] FLIP-611: Running Flink jobs in MiniCluster using the Kubernetes Operator Zhanghao Chen
• 2026/09/17 Re: FLIP-608: Flink on Ray — Ray Resource Backend For Flink Zhanghao Chen
• 2026/09/17 [jira] [Created] (FLINK-40704) Enable spotless for java25 Sergey Nuyanzin (Jira)
• 2026/09/17 Re: [VOTE] Apache Flink Kubernetes Operator Release 1.16.1, release candidate #1 P Sinha
• 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: [DISCUSS] Operator 1.16.1 patch release due to serious bug with observed runtime config feature Dennis-Mircea Ciupitu
• 2026/09/17 Re: Review request: FLINK-39775 (Flink CDC, MySQL source) - PR #4418 Spoorthi Basu
• 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 Re: [DISCUSS] FLIP-XXXX: Higher-Order Functions in Flink SQL (TRANSFORM and ARRAY_FILTER) Martijn Visser
• 2026/09/17 [jira] [Created] (FLINK-40702) Unify shared HTTP sink and lookup configuration options Bharath Reddy Gunapati (Jira)
• 2026/09/17 Re: [DISCUSS] Operator 1.16.1 patch release due to serious bug with observed runtime config feature Robert Metzger
• 2026/09/17 [jira] [Created] (FLINK-40701) Upgrade ArchUnit to 1.5.0 Martijn Visser (Jira)
• 2026/09/17 Re: [DISCUSS] FLIP-612: Native XML Functions for Flink SQL Fabian Hüske via dev
• 2026/09/17 [jira] [Created] (FLINK-40700) Add typed DataStream configuration for HTTP sink options Bharath Reddy Gunapati (Jira)
• 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-40698) Bump japicmp-maven-plugin to 0.26.2 Martijn Visser (Jira)
• 2026/09/17 Re: [DISCUSS] Promoting flink-s3-fs-native from @Experimental to a mainstream S3FileSystem Samrat Deb
• 2026/09/17 [DISCUSS] Operator 1.16.1 patch release due to serious bug with observed runtime config feature Gyula Fóra
• 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: [VOTE] FLIP-611: Running Flink jobs in MiniCluster using the Kubernetes Operator Dennis-Mircea Ciupitu
• 2026/09/17 Re: [DISCUSS] FLIP-612: Native XML Functions for Flink SQL Krishna Sai
• 2026/09/17 [VOTE] Apache Flink Kubernetes Operator Release 1.16.1, release candidate #1 Gyula Fóra
• 2026/09/17 Re: [DISCUSS] FLIP-612: Native XML Functions for Flink SQL Moritz Manner
• 2026/09/17 [jira] [Created] (FLINK-40696) Revert observed runtime config logic Gyula Fora (Jira)
• 2026/09/17 Re: [DISCUSS] Operator 1.16.1 patch release due to serious bug with observed runtime config feature P Sinha
• 2026/09/17 [jira] [Created] (FLINK-40695) Transient issues during ExecutionGraph creation lead to terminal job Failure Ahmed Hamdy (Jira)
• 2026/09/17 [REMINDER] Flink 2.4 Release Sync - 18.09.26 Chanhae Oh
• 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] [Created] (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-40691) Fix comparison logic for binlog filename with more than 6 digits Yanquan Lv (Jira)
• 2026/09/17 Re: [DISCUSS] Planning Flink CDC 3.7 release Xiqian YU
• 2026/09/17 Re: [DISCUSS] Remove Deprecated Configuration Options/Keys in Flink Yuepeng Pan
• 2026/09/17 [jira] [Created] (FLINK-40690) Fluss sink applies top-level column mapping to nested ROW fields Xiaobing Fang (Jira)
• 2026/09/16 Re: [Flink CDC][postgres] JobManager connection pool exhausted after 20 incremental-snapshot jobs: JdbcSourceChunkSplitter keeps a pooled JDBC connection for the whole job lifetime Kyrie
• 2026/09/16 RE: [Flink CDC][postgres] JobManager connection pool exhausted after 20 incremental-snapshot jobs: JdbcSourceChunkSplitter keeps a pooled JDBC connection for the whole job lifetime Hongshun Wang

• Earlier messages