snuyanzin commented on code in PR #832: URL: https://github.com/apache/flink-web/pull/832#discussion_r2904999533
########## docs/content/posts/2026-03-01-community-update.md: ########## @@ -0,0 +1,146 @@ +--- +authors: +- davidrad: null + name: David Radley +date: "2026-03-01T08:00:00Z" +excerpt: Flink Community update for March 2026 +title: Flink Community update for March 2026 +aliases: +- /news/2026/03/01/community-update.html +--- + +<!-- TOC --> + * [What happened last month](#what-happened-last-month) + * [Blogs](#blogs) + * [Apache Flink Dev List activity](#apache-flink-dev-list-activity) + * [Key Themes](#key-themes) + * [Community Announcements](#community-announcements) + * [FLIP Activity](#flip-activity) + * [Accepted - being implemented](#accepted---being-implemented) + * [Being discussed](#being-discussed) + * [Kubernetes Operator 1.14.0 Release](#kubernetes-operator-1140-release) + * [Apache Flink Connector Parent 2.0.0 Release](#apache-flink-connector-parent-200-release) + * [Apache Flink Connector AWS 6.0 Release](#apache-flink-connector-aws-60-release) + * [Apache Flink Agents 0.2.0 released](#apache-flink-agents-020-released) + * [For more information](#for-more-information) +<!-- TOC --> + +Previous Blog: [Flink community update February 2026](https://flink.apache.org/2026/02/01/flink-community-update-february26/) + +A strong February; there was a lot of commit activity with 320 open PRs and 4 new releases. + +## What happened last month +* Flink + * [Release planning](https://lists.apache.org/thread/o1lsjzmh2np1fp3b5dk0x6bwzqg4cvw5) for Flink 2.3 ongoing. + * All CI builds were failing; this was fixed in a [PR](https://github.com/apache/flink/pull/27619) that upgraded Kubernetes client libraries. +* Connector parent + * Added [license checking](https://github.com/apache/flink-connector-shared-utils/commit/6e1af169012db40306a56ba8bcf31bb8a309e6e6) to Parent Connector. +* Flink JDBC connector + * [FLINK-38851](https://issues.apache.org/jira/browse/FLINK-38851) Support passing arbitrary database options to JDBC Catalog. +* Flink Kafka connector had 14 commits going in. The most interesting were: + * [FLINK-39012](https://issues.apache.org/jira/browse/FLINK-39012) Support global enumerator/dispatcher for dynamic Kafka source (handling multiple cluster topologies) + * [FLINK-39120](https://issues.apache.org/jira/browse/FLINK-39120) Update to Kafka 4.2.0. + +## Blogs + +* Rion Williams - [Prepare for Launch: Enrichment Strategies for Apache Flink](https://rion.io/2026/01/27/prepare-for-launch-enrichment-strategies-for-apache-flink/) +* Hongshun Wang - [Fluss 0.9 + Flink CDC V3.6 (coming soon) = production level schema evolution](https://www.linkedin.com/posts/hongshun-wang-82169a233_apachefluss-streamhouse-opensource-activity-7434953224673181696-sfrO?utm_source=share&utm_medium=member_desktop&rcm=ACoAAAEGQNUBcKgSajZ7VR3bxeiquOHZcR2Gq80) +* Robin Moffatt was kind enough to point me to his list of [Interesting Links - February 2026 (Stream Processing section)](https://rmoff.net/2026/02/27/interesting-links-february-2026/#_stream_processing) + * Lots of interesting Flink blogs here. + +## Apache Flink Dev List activity + +You can view the dev list archives [online](https://lists.apache.org/[email protected]) or [subscribe](https://flink.apache.org/community.html#mailing-lists) to receive emails. + +### Key Themes + +1. Additional Serviceability + - [[FLINK-38977] Expose exceptions for applications](https://issues.apache.org/jira/browse/FLINK-38977) + - [[hotfix] Log watermark alignment duration (and all other stages)](https://github.com/apache/flink/commit/f6fffd7d33f617acc69f405deecf050ef710d439) + - [[hotfix] Log unexpected non-terminal task state](https://github.com/apache/flink/commit/79e79fcd26eeaabb956198ce2c6293cc221a9f5e) +2. Improvements to watermarks + - [[FLINK-37399] Buffer watermarks for watermark alignment](https://issues.apache.org/jira/browse/FLINK-37399) + - [[FLINK-37399] Add SamplingWatermarkRingBuffer](https://issues.apache.org/jira/browse/FLINK-37399) + - [[FLINK-39167] Initialize source output before emitting final watermark](https://issues.apache.org/jira/browse/FLINK-39167) +3. Improved recovery with checkpoints + - [[hotfix] Try to get last checkpoint on recovery regardless of checkpointing interval](https://github.com/apache/flink/commit/c0ada39aafa23e58e6c80883bdb740a89d02c1ff) + - [[hotfix] Move checkpointing configuration code to CheckpointCoordinatorConfiguration](https://github.com/apache/flink/commit/b2b044dc66814498f0cdfb4e9249f446e2c6fce9) + - [[FLINK-38939] Pause Sources until the first checkpoint barrier is received](https://issues.apache.org/jira/browse/FLINK-38939) +4. Enhancements around splits + - [[FLINK-39073] Test split state timers during deferred alignment check](https://issues.apache.org/jira/browse/FLINK-39073) + - [[FLINK-39073] Improve logging of invalid split transitions](https://issues.apache.org/jira/browse/FLINK-39073) + - [[FLINK-39073] Defer alignment check for idle splits](https://issues.apache.org/jira/browse/FLINK-39073) +5. Table planner enhancements + - [[FLINK-37924] Introduce Built-in Function to Access field or element in the Variant](https://issues.apache.org/jira/browse/FLINK-37924) + - [[FLINK-35661] Fix MiniBatchGroupAggFunction silently dropping records](https://issues.apache.org/jira/browse/FLINK-35661) + - [[FLINK-38913] ArrayIndexOutOfBoundsException while unparsing ExtendedSqlRowTypeNameSpec](https://issues.apache.org/jira/browse/FLINK-38913) + - [[FLINK-39088] Fix upsert key preservation by introducing injective cast checks for CAST](https://issues.apache.org/jira/browse/FLINK-39088) + - [[FLINK-39088] Support injective casts from CHAR/VARCHAR to BINARY/VARBINARY](https://issues.apache.org/jira/browse/FLINK-39088) + - [[FLINK-38624] Type Mismatch Exception in StreamPhysicalOverAggregateRule](https://issues.apache.org/jira/browse/FLINK-38624) + - [[FLINK-38624] Replace deprecated RexBuilder#makeAbstractCast](https://issues.apache.org/jira/browse/FLINK-38624) + - [[FLINK-38624] Convert FlinkLogicalOverAggregate to java](https://issues.apache.org/jira/browse/FLINK-38624) Review Comment: any reason we need to include all commits here? these 2 e.g. are just refactor/technical debt, i don't see any reason to have them here since I can't answer question: what the reader can benefit after reading this? at the same time for instance > - [[FLINK-38624] Type Mismatch Exception in StreamPhysicalOverAggregateRule](https://issues.apache.org/jira/browse/FLINK-38624) this makes sense since it was a breaking change in 2.0 and might be a blocker for someone while migration from 1.20 to 2.x, now it is fixed -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
