Add April 2026 Flink community update blog post#839
Open
jlpayne72 wants to merge 9 commits intoapache:asf-sitefrom
Open
Add April 2026 Flink community update blog post#839jlpayne72 wants to merge 9 commits intoapache:asf-sitefrom
jlpayne72 wants to merge 9 commits intoapache:asf-sitefrom
Conversation
Enhanced readability of the April 2026 Flink Community update by breaking long paragraphs into shorter ones for better clarity.
rmoff
suggested changes
Apr 14, 2026
rmoff
left a comment
rmoff
left a comment
There was a problem hiding this comment.
thanks for doing this @jlpayne72!
I've left some notes and suggestions.
davidradl
reviewed
Apr 14, 2026
davidradl
reviewed
Apr 14, 2026
snuyanzin
reviewed
Apr 14, 2026
snuyanzin
reviewed
Apr 14, 2026
snuyanzin
reviewed
Apr 14, 2026
snuyanzin
reviewed
Apr 14, 2026
snuyanzin
reviewed
Apr 14, 2026
Co-authored-by: Robin Moffatt <robin@rmoff.net>
Defined what a FLIP Is for new readers
snuyanzin
reviewed
Apr 14, 2026
snuyanzin
reviewed
Apr 14, 2026
snuyanzin
requested changes
Apr 14, 2026
Co-authored-by: Sergey Nuyanzin <snuyanzin@confluent.io>
Removed documentation section detailing March updates.
Moved developer updates to user-facing updates section, ensuring clarity in the community update.
davidradl
reviewed
Apr 23, 2026
Contributor
davidradl
left a comment
davidradl
left a comment
There was a problem hiding this comment.
8 hardcoded flink.apache.org links should be changed to relative paths (lines 28, 38, 88, 100, 128, 131, 132, 136)
|
|
||
| Flink CDC is used to capture and stream real-time changes from databases (inserts, updates, and deletes) as they happen. | ||
| If you missed it, you can read the [launch announcement](https://flink.apache.org/2026/03/30/apache-flink-cdc-3.6.0-release-announcement/). | ||
| Version 3.6.0 extends Flink version support to 1.20.x and 2.2.x, upgrades JDK version to 11, introduces new Oracle Source and Apache Hudi Sink Pipeline connectors and adds Lenient mode schema evolution support for Fluss Pipeline connector. |
Contributor
There was a problem hiding this comment.
it would be great highlight the business value of each of these things, with hyper links for each of them.
| Flink CDC is used to capture and stream real-time changes from databases (inserts, updates, and deletes) as they happen. | ||
| If you missed it, you can read the [launch announcement](https://flink.apache.org/2026/03/30/apache-flink-cdc-3.6.0-release-announcement/). | ||
| Version 3.6.0 extends Flink version support to 1.20.x and 2.2.x, upgrades JDK version to 11, introduces new Oracle Source and Apache Hudi Sink Pipeline connectors and adds Lenient mode schema evolution support for Fluss Pipeline connector. | ||
| It also introduces PostgreSQL Schema Evolution support, enhances Schema Evolution capabilities for better multi-table synchronization scenarios and table name mapping flexibility, and strengthens the Transform framework with VARIANT type and JSON parsing support. |
| We want to re-structure Flink documentation to aid discoverability and reduce duplication (see [FLIP-561](https://cwiki.apache.org/confluence/display/FLINK/FLIP-561%3A+Restructure+Flink+documentation)). | ||
| Reflecting the broadening use of SQL we plan to create a dedicated Flink SQL section separate from Table API. | ||
| We will move shared concepts (Relational Streaming concepts like Dynamic Tables, Time Attributes) to the top-level Concepts section and also move shared architecture documentation (Source/Sink APIs) to the Connectors section. | ||
| Additionally, Python documentation will now be integrated within the Table API and DataStream API sections where applicable, with the rest moved to the Python API docs (PyDocs). |
Contributor
There was a problem hiding this comment.
maybe describe what the rest means
|
|
||
| Continued work on Materialized Tables including `START_MODE` clause parser support ([[FLINK-39304]](https://issues.apache.org/jira/browse/FLINK-39304), [[#27843]](https://github.com/apache/flink/pull/27843)), interval reuse for `FRESHNESS` and `START MODE` ([[#27845]](https://github.com/apache/flink/pull/27845)), and `CREATE OR ALTER` now correctly respects existing table schemas ([[FLINK-39284]](https://issues.apache.org/jira/browse/FLINK-39284), [[#27854]](https://github.com/apache/flink/pull/27854)). `TO_CHANGELOG` retract/upsert stream conversion was also added ([[#27847]](https://github.com/apache/flink/pull/27847)). | ||
|
|
||
| BITMAP Type support was introduced end-to-end: the core data type ([[FLINK-38852]](https://issues.apache.org/jira/browse/FLINK-38852), [[FLINK-39185]](https://issues.apache.org/jira/browse/FLINK-39185)), scalar functions ([[FLINK-39186]](https://issues.apache.org/jira/browse/FLINK-39186)), aggregate functions ([[FLINK-39187]](https://issues.apache.org/jira/browse/FLINK-39187)), and documentation ([[FLINK-39188]](https://issues.apache.org/jira/browse/FLINK-39188), [[#27835]](https://github.com/apache/flink/pull/27835)). |
Contributor
There was a problem hiding this comment.
you could add - the value of BITMAP is ....
|
|
||
| BITMAP Type support was introduced end-to-end: the core data type ([[FLINK-38852]](https://issues.apache.org/jira/browse/FLINK-38852), [[FLINK-39185]](https://issues.apache.org/jira/browse/FLINK-39185)), scalar functions ([[FLINK-39186]](https://issues.apache.org/jira/browse/FLINK-39186)), aggregate functions ([[FLINK-39187]](https://issues.apache.org/jira/browse/FLINK-39187)), and documentation ([[FLINK-39188]](https://issues.apache.org/jira/browse/FLINK-39188), [[#27835]](https://github.com/apache/flink/pull/27835)). | ||
|
|
||
| Join Operations saw cascaded delta join support merged ([[FLINK-39233]](https://issues.apache.org/jira/browse/FLINK-39233), [[#27828]](https://github.com/apache/flink/pull/27828)), lookup join after delta join ([[FLINK-39174]](https://issues.apache.org/jira/browse/FLINK-39174)), and immutable column sink mode traits ([[FLINK-39287]](https://issues.apache.org/jira/browse/FLINK-39287), [[#27838]](https://github.com/apache/flink/pull/27838)). |
Contributor
There was a problem hiding this comment.
maybe say - allowing the delta join to be used in more scenarios.
|
|
||
| ### Runtime & Execution | ||
|
|
||
| Adaptive scheduler and `ExecutionGraph` improvements will be part of Flink 2.3. Rescale history now records statistics ([[#27540]](https://github.com/apache/flink/pull/27540)) and rescale information ([[#27539]](https://github.com/apache/flink/pull/27539)). A configurable `ExecutionGraph` cache TTL was introduced ([[#27509]](https://github.com/apache/flink/pull/27509)), and the Flink Web UI was updated to surface rescale and configuration data for adaptive scheduler jobs ([[#27826]](https://github.com/apache/flink/pull/27826)). |
Contributor
There was a problem hiding this comment.
a notice the tenses change. There will be improvements in 2.3. Rescale history now records, and the cache TTL was introduced and UI was updated.
|
|
||
| ### Checkpointing & State | ||
|
|
||
| Unaligned checkpoint recovery gained a new configuration option ([[FLINK-38541]](https://issues.apache.org/jira/browse/FLINK-38541), [[#27782]](https://github.com/apache/flink/pull/27782)), giving operators finer control over recovery behaviour under failure conditions. Session-mode HA recovery re-execution was also resolved ([[FLINK-38975]](https://issues.apache.org/jira/browse/FLINK-38975)). |
Contributor
There was a problem hiding this comment.
what does was resolved means in the sentence " Session-mode HA recovery re-execution was also resolved". I am not sure how to read this , is it fixing something or introducing something
davidradl
reviewed
Apr 23, 2026
|
|
||
| ### FLIPs (under discussion) | ||
|
|
||
| * **[FLIP-202](https://cwiki.apache.org/confluence/display/FLINK/FLIP-202): [DRAFT] Introduce ClickHouse Connector.** - Community discussion ongoing for an officially supported ClickHouse sink connector. |
Contributor
There was a problem hiding this comment.
these 3 flips do not seem to have had march activity
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
4 participants
Add this suggestion to a batch that can be applied as a single commit.This suggestion is invalid because no changes were made to the code.Suggestions cannot be applied while the pull request is closed.Suggestions cannot be applied while viewing a subset of changes.Only one suggestion per line can be applied in a batch.Add this suggestion to a batch that can be applied as a single commit.Applying suggestions on deleted lines is not supported.You must change the existing code in this line in order to create a valid suggestion.Outdated suggestions cannot be applied.This suggestion has been applied or marked resolved.Suggestions cannot be applied from pending reviews.Suggestions cannot be applied on multi-line comments.Suggestions cannot be applied while the pull request is queued to merge.Suggestion cannot be applied right now. Please check back later.
Summary
Monthly community update blog post for April 2026, covering March 2026 activity.
Format follows the March 2026 post (#832).
🤖 Generated with Claude Code