Re: [PR] Community blog March 2026 [flink-web]
davidradl commented on PR #832: URL: https://github.com/apache/flink-web/pull/832#issuecomment-4066088171 @snuyanzin @rmoff I have made changes to the review comments. I would like to get this out asap. Please let me know if you want anything changes asap. If I do not hear anything by end of Tuesday, I will merge Wednesday. -- 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]
Re: [PR] Community blog March 2026 [flink-web]
davidradl commented on code in PR #832: URL: https://github.com/apache/flink-web/pull/832#discussion_r2938962142 ## docs/content/posts/2026-03-01-community-update.md: ## @@ -0,0 +1,148 @@ +--- +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 +--- + + + * [Developer/Technical Updates](#developertechnical-updates) +* [Key Themes](#key-themes) +* [What happened last month](#what-happened-last-month) + * [User-Facing Updates](#user-facing-updates) +* [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) +* [Blogs](#blogs) + * [Governance and Community](#governance-and-community) +* [FLIP Activity](#flip-activity) + * [Accepted - being implemented](#accepted---being-implemented) + * [Being discussed](#being-discussed) +* [Apache Flink Dev List activity](#apache-flink-dev-list-activity) + * [For more information](#for-more-information) + + +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 in the main repository (600+ across all Flink projects) and 4 new releases. + +## Developer/Technical Updates + +### 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 Review Comment: Added a link to the split definition -- 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]
Re: [PR] Community blog March 2026 [flink-web]
davidradl commented on code in PR #832: URL: https://github.com/apache/flink-web/pull/832#discussion_r2938913735 ## 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 +--- + + + * [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) + + +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. Review Comment: @snuyanzin I will remove this for now so we can get this out. I will look at add somehing like this in subsequent months -- 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]
Re: [PR] Community blog March 2026 [flink-web]
davidradl commented on code in PR #832: URL: https://github.com/apache/flink-web/pull/832#discussion_r2925841478 ## 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 +--- + + + * [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) + + +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. Review Comment: @snuyanzin I understand your point. If I had taken a screen shot of the repo pulse then I could have got a view of the core repository, but unfortunately I did not do that and that would be just for one repo. If I write a script to find the the number of opened PRs and merged PRs, I would need to do this for each repo that was active. I can do that, but a lot of the feedback from last month is that this should be evidence based. I could publish the script in the repo and link to it. What do you think of this as a way forward? -- 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]
Re: [PR] Community blog March 2026 [flink-web]
davidradl commented on code in PR #832: URL: https://github.com/apache/flink-web/pull/832#discussion_r2925748885 ## docs/content/posts/2026-03-01-community-update.md: ## @@ -0,0 +1,148 @@ +--- +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 +--- + + + * [Developer/Technical Updates](#developertechnical-updates) +* [Key Themes](#key-themes) +* [What happened last month](#what-happened-last-month) + * [User-Facing Updates](#user-facing-updates) +* [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) +* [Blogs](#blogs) + * [Governance and Community](#governance-and-community) +* [FLIP Activity](#flip-activity) + * [Accepted - being implemented](#accepted---being-implemented) + * [Being discussed](#being-discussed) +* [Apache Flink Dev List activity](#apache-flink-dev-list-activity) + * [For more information](#for-more-information) + + +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 in the main repository (600+ across all Flink projects) and 4 new releases. + +## Developer/Technical Updates + +### 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) Review Comment: In the previous month I had put forwards some trends but was asked to evidence base them. This is why I left these in.. If I remove them I lose the evidence that this is a trend. WDYT? -- 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]
Re: [PR] Community blog March 2026 [flink-web]
davidradl commented on code in PR #832: URL: https://github.com/apache/flink-web/pull/832#discussion_r2925734927 ## docs/content/posts/2026-03-01-community-update.md: ## @@ -0,0 +1,148 @@ +--- +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 +--- + + + * [Developer/Technical Updates](#developertechnical-updates) +* [Key Themes](#key-themes) +* [What happened last month](#what-happened-last-month) + * [User-Facing Updates](#user-facing-updates) +* [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) +* [Blogs](#blogs) + * [Governance and Community](#governance-and-community) +* [FLIP Activity](#flip-activity) + * [Accepted - being implemented](#accepted---being-implemented) + * [Being discussed](#being-discussed) +* [Apache Flink Dev List activity](#apache-flink-dev-list-activity) + * [For more information](#for-more-information) + + +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 in the main repository (600+ across all Flink projects) and 4 new releases. + +## Developer/Technical Updates + +### 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] 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) Review Comment: ok will remove -- 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]
Re: [PR] Community blog March 2026 [flink-web]
davidradl commented on code in PR #832: URL: https://github.com/apache/flink-web/pull/832#discussion_r2925738832 ## docs/content/posts/2026-03-01-community-update.md: ## @@ -0,0 +1,148 @@ +--- +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 +--- + + + * [Developer/Technical Updates](#developertechnical-updates) +* [Key Themes](#key-themes) +* [What happened last month](#what-happened-last-month) + * [User-Facing Updates](#user-facing-updates) +* [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) +* [Blogs](#blogs) + * [Governance and Community](#governance-and-community) +* [FLIP Activity](#flip-activity) + * [Accepted - being implemented](#accepted---being-implemented) + * [Being discussed](#being-discussed) +* [Apache Flink Dev List activity](#apache-flink-dev-list-activity) + * [For more information](#for-more-information) + + +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 in the main repository (600+ across all Flink projects) and 4 new releases. + +## Developer/Technical Updates + +### 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] 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-38624] Type Mismatch Exception in StreamPhysicalOverAggregateRule](https://issues.apache.org/jira/browse/FLINK-38624) Fix for a breaking change, that occurs migrating from 1.20 to 2.x. + +### What happened last month +* Flink + * 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. Review Comment: ok will remove -- 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]
Re: [PR] Community blog March 2026 [flink-web]
snuyanzin commented on code in PR #832: URL: https://github.com/apache/flink-web/pull/832#discussion_r2916298414 ## docs/content/posts/2026-03-01-community-update.md: ## @@ -0,0 +1,148 @@ +--- +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 +--- + + + * [Developer/Technical Updates](#developertechnical-updates) +* [Key Themes](#key-themes) +* [What happened last month](#what-happened-last-month) + * [User-Facing Updates](#user-facing-updates) +* [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) +* [Blogs](#blogs) + * [Governance and Community](#governance-and-community) +* [FLIP Activity](#flip-activity) + * [Accepted - being implemented](#accepted---being-implemented) + * [Being discussed](#being-discussed) +* [Apache Flink Dev List activity](#apache-flink-dev-list-activity) + * [For more information](#for-more-information) + + +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 in the main repository (600+ across all Flink projects) and 4 new releases. + +## Developer/Technical Updates + +### 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 Review Comment: this is very vague definition. For instance a question that might pop up after first reading: we have `code-splitter` module, does it have anything in common? -- 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]
Re: [PR] Community blog March 2026 [flink-web]
snuyanzin commented on code in PR #832: URL: https://github.com/apache/flink-web/pull/832#discussion_r2916288905 ## docs/content/posts/2026-03-01-community-update.md: ## @@ -0,0 +1,148 @@ +--- +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 +--- + + + * [Developer/Technical Updates](#developertechnical-updates) +* [Key Themes](#key-themes) +* [What happened last month](#what-happened-last-month) + * [User-Facing Updates](#user-facing-updates) +* [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) +* [Blogs](#blogs) + * [Governance and Community](#governance-and-community) +* [FLIP Activity](#flip-activity) + * [Accepted - being implemented](#accepted---being-implemented) + * [Being discussed](#being-discussed) +* [Apache Flink Dev List activity](#apache-flink-dev-list-activity) + * [For more information](#for-more-information) + + +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 in the main repository (600+ across all Flink projects) and 4 new releases. + +## Developer/Technical Updates + +### 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] 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) Review Comment: to be more precise this is not a planner change, rather parser -- 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]
Re: [PR] Community blog March 2026 [flink-web]
snuyanzin commented on code in PR #832: URL: https://github.com/apache/flink-web/pull/832#discussion_r2915048224 ## 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 +--- + + + * [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) + + +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. Review Comment: my point is that if we are talking about what's changed for the month, then we shouldn't operate things like total, rather how many PRs were submitted and how many were merged within this month -- 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]
Re: [PR] Community blog March 2026 [flink-web]
snuyanzin commented on code in PR #832: URL: https://github.com/apache/flink-web/pull/832#discussion_r2915040531 ## docs/content/posts/2026-03-01-community-update.md: ## @@ -0,0 +1,148 @@ +--- +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 +--- + + + * [Developer/Technical Updates](#developertechnical-updates) +* [Key Themes](#key-themes) +* [What happened last month](#what-happened-last-month) + * [User-Facing Updates](#user-facing-updates) +* [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) +* [Blogs](#blogs) + * [Governance and Community](#governance-and-community) +* [FLIP Activity](#flip-activity) + * [Accepted - being implemented](#accepted---being-implemented) + * [Being discussed](#being-discussed) +* [Apache Flink Dev List activity](#apache-flink-dev-list-activity) + * [For more information](#for-more-information) + + +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 in the main repository (600+ across all Flink projects) and 4 new releases. + +## Developer/Technical Updates + +### 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] 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-38624] Type Mismatch Exception in StreamPhysicalOverAggregateRule](https://issues.apache.org/jira/browse/FLINK-38624) Fix for a breaking change, that occurs migrating from 1.20 to 2.x. + +### What happened last month +* Flink + * 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. Review Comment: I tend to think nobody is interested in license checking except for people who are directly involved in development/release process wdyt? -- 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]
Re: [PR] Community blog March 2026 [flink-web]
snuyanzin commented on code in PR #832: URL: https://github.com/apache/flink-web/pull/832#discussion_r2915036049 ## docs/content/posts/2026-03-01-community-update.md: ## @@ -0,0 +1,148 @@ +--- +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 +--- + + + * [Developer/Technical Updates](#developertechnical-updates) +* [Key Themes](#key-themes) +* [What happened last month](#what-happened-last-month) + * [User-Facing Updates](#user-facing-updates) +* [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) +* [Blogs](#blogs) + * [Governance and Community](#governance-and-community) +* [FLIP Activity](#flip-activity) + * [Accepted - being implemented](#accepted---being-implemented) + * [Being discussed](#being-discussed) +* [Apache Flink Dev List activity](#apache-flink-dev-list-activity) + * [For more information](#for-more-information) + + +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 in the main repository (600+ across all Flink projects) and 4 new releases. + +## Developer/Technical Updates + +### 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) Review Comment: do we really need all these hotfix commits description? ## docs/content/posts/2026-03-01-community-update.md: ## @@ -0,0 +1,148 @@ +--- +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 +--- + + + * [Developer/Technical Updates](#developertechnical-updates) +* [Key Themes](#key-themes) +* [What happened last month](#what-happened-last-month) + * [User-Facing Updates](#user-facing-updates) +* [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) +* [Blogs](#blogs) + * [Governance and Community](#governance-and-community) +* [FLIP Activity](#flip-activity) + * [Accepted - being implemented](#accepted---being-implemented) + * [Being discussed](#being-discussed) +* [Apache Flink Dev List activity](#apache-flink-dev-list-activity) + * [For more information](#for-more-information) + + +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 in the main repository (600+ across all Flink projects) and 4 new releases. + +## Developer/Technical Updates + +### 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) Review Comment: do we really need all these hotfix commits description here? -- 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]
Re: [PR] Community blog March 2026 [flink-web]
davidradl commented on code in PR #832: URL: https://github.com/apache/flink-web/pull/832#discussion_r2913613359 ## docs/content/posts/2026-03-01-community-update.md: ## @@ -0,0 +1,145 @@ +--- +authors: +- davidrad: null + name: David Radley +date: "2026-03-01T08:00:00Z" +excerpt: Flink Community update for March 2026 +title: Flink Community Update - March'26 +aliases: +- /news/2026/03/01/community-update.html +--- + + + * [February 2026 overview](#february-2026-overview) + * [Flink related Blogs](#flink-related-blogs) + * [Summary of Apache Flink Dev List (covering February 2026)](#summary-of-apache-flink-dev-list-covering-february-2026) +* [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) + Review Comment: On your suggestion add 3 parts the indentation is now one deeper. -- 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]
Re: [PR] Community blog March 2026 [flink-web]
davidradl commented on code in PR #832: URL: https://github.com/apache/flink-web/pull/832#discussion_r2911308716 ## 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 +--- + + + * [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) + + +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. Review Comment: I understand your concern - this is inconsistent: 1 I can say something like "A strong February; there was a lot of commit activity with 320 open PRs in the main repository (600+ across all Flink projects) and 4 new releases." 2 I realise we are only really interested in active repositories, i.e. ones where something has happened in February. I can give those numbers - but then I will be asked to evidence base them. I could share a shell script in the repo. 3 the total commits - is useful really for the repos with stale bot on. Otherwise the total commits could be very old. I am tempted for 1 to keep it simple, but am open to suggestions. WDYT? -- 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]
Re: [PR] Community blog March 2026 [flink-web]
davidradl commented on code in PR #832: URL: https://github.com/apache/flink-web/pull/832#discussion_r2911040311 ## 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 +--- + + + * [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) + + +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. Review Comment: Understood - I think it best to give credit so posted your link directly. I can move this sentence after the link and remove the sub bullet. -- 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]
Re: [PR] Community blog March 2026 [flink-web]
davidradl commented on code in PR #832: URL: https://github.com/apache/flink-web/pull/832#discussion_r2910993913 ## 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 +--- + + + * [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) + + +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 inval
Re: [PR] Community blog March 2026 [flink-web]
rmoff commented on code in PR #832: URL: https://github.com/apache/flink-web/pull/832#discussion_r2905127250 ## 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 +--- + + + * [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) + + +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. Review Comment: @davidradl FWIW I actually meant use my blog post as a source of interesting Flink posts to include in yours. But including it directly is fine too :) -- 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]
Re: [PR] Community blog March 2026 [flink-web]
snuyanzin commented on code in PR #832: URL: https://github.com/apache/flink-web/pull/832#discussion_r2905108567 ## 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 +--- + + + * [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) + + +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. Review Comment: >total in the core repo. then we need to have the same approach, like why commits are mentioned only for main repo and releases across all projects ? -- 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]
Re: [PR] Community blog March 2026 [flink-web]
snuyanzin commented on code in PR #832: URL: https://github.com/apache/flink-web/pull/832#discussion_r2905101970 ## 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 +--- + + + * [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) + + +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. Review Comment: in your list every new item is under a separate bullet and this one was also under a separate bullet, that's why I have this question -- 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]
Re: [PR] Community blog March 2026 [flink-web]
davidradl commented on code in PR #832: URL: https://github.com/apache/flink-web/pull/832#discussion_r2905093458 ## 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 +--- + + + * [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) + + +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. Review Comment: the link is in the line above. I could go into more detail - I thought a comment would be helpful to provide context as to why this was included. -- 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]
Re: [PR] Community blog March 2026 [flink-web]
davidradl commented on code in PR #832: URL: https://github.com/apache/flink-web/pull/832#discussion_r2905087077 ## 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 +--- + + + * [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) + + +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. Review Comment: total in the core repo. I will clarify that -- 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]
Re: [PR] Community blog March 2026 [flink-web]
davidradl commented on code in PR #832: URL: https://github.com/apache/flink-web/pull/832#discussion_r2904989976 ## docs/content/posts/2026-03-01-community-update.md: ## @@ -0,0 +1,145 @@ +--- +authors: +- davidrad: null + name: David Radley +date: "2026-03-01T08:00:00Z" +excerpt: Flink Community update for March 2026 +title: Flink Community Update - March'26 +aliases: +- /news/2026/03/01/community-update.html +--- + + + * [February 2026 overview](#february-2026-overview) + * [Flink related Blogs](#flink-related-blogs) + * [Summary of Apache Flink Dev List (covering February 2026)](#summary-of-apache-flink-dev-list-covering-february-2026) +* [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) + Review Comment: I think the TOC it is useful - I take your point about the depth I will move the content under [Apache Flink Dev List activity](#apache-flink-dev-list-activity) to the top level. -- 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]
Re: [PR] Community blog March 2026 [flink-web]
snuyanzin commented on code in PR #832: URL: https://github.com/apache/flink-web/pull/832#discussion_r2905029440 ## 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 +--- + + + * [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) + + +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. + Review Comment: is there a reason to keep activity in other repos separate? I'm still not convinced we need to put all the commits, may be rather having kind of summary with some highlights -- 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]
Re: [PR] Community blog March 2026 [flink-web]
snuyanzin commented on code in PR #832: URL: https://github.com/apache/flink-web/pull/832#discussion_r2905014818 ## 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 +--- + + + * [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) + + +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 inval
Re: [PR] Community blog March 2026 [flink-web]
snuyanzin commented on code in PR #832: URL: https://github.com/apache/flink-web/pull/832#discussion_r2905012621 ## 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 +--- + + + * [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) + + +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. Review Comment: didn't get what it is about, there is no any link -- 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]
Re: [PR] Community blog March 2026 [flink-web]
snuyanzin commented on code in PR #832: URL: https://github.com/apache/flink-web/pull/832#discussion_r2905007656 ## 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 +--- + + + * [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) + + +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. Review Comment: do we have 320 PRs opened within one months? is it a number for just Flink repo, I guess releases are counted here not only for the Flink main repo -- 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]
Re: [PR] Community blog March 2026 [flink-web]
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 +--- + + + * [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) + + +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 inval
Re: [PR] Community blog March 2026 [flink-web]
davidradl commented on code in PR #832: URL: https://github.com/apache/flink-web/pull/832#discussion_r2904989976 ## docs/content/posts/2026-03-01-community-update.md: ## @@ -0,0 +1,145 @@ +--- +authors: +- davidrad: null + name: David Radley +date: "2026-03-01T08:00:00Z" +excerpt: Flink Community update for March 2026 +title: Flink Community Update - March'26 +aliases: +- /news/2026/03/01/community-update.html +--- + + + * [February 2026 overview](#february-2026-overview) + * [Flink related Blogs](#flink-related-blogs) + * [Summary of Apache Flink Dev List (covering February 2026)](#summary-of-apache-flink-dev-list-covering-february-2026) +* [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) + Review Comment: I think the TOC it is useful - I take your point about the depth I will remove the [Apache Flink Dev List activity](#apache-flink-dev-list-activity) -- 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]
Re: [PR] Community blog March 2026 [flink-web]
rmoff commented on code in PR #832: URL: https://github.com/apache/flink-web/pull/832#discussion_r2904401798 ## docs/content/posts/2026-03-01-community-update.md: ## @@ -0,0 +1,145 @@ +--- +authors: +- davidrad: null + name: David Radley +date: "2026-03-01T08:00:00Z" +excerpt: Flink Community update for March 2026 +title: Flink Community Update - March'26 +aliases: +- /news/2026/03/01/community-update.html +--- + + + * [February 2026 overview](#february-2026-overview) + * [Flink related Blogs](#flink-related-blogs) + * [Summary of Apache Flink Dev List (covering February 2026)](#summary-of-apache-flink-dev-list-covering-february-2026) +* [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) + + +Previous Blog: +[Flink community update February 2026](https://flink.apache.org/2026/02/01/flink-community-update-february26/) Review Comment: ```suggestion ``` not sure you need this ## docs/content/posts/2026-03-01-community-update.md: ## @@ -0,0 +1,145 @@ +--- +authors: +- davidrad: null + name: David Radley +date: "2026-03-01T08:00:00Z" +excerpt: Flink Community update for March 2026 +title: Flink Community Update - March'26 +aliases: +- /news/2026/03/01/community-update.html +--- + + + * [February 2026 overview](#february-2026-overview) + * [Flink related Blogs](#flink-related-blogs) + * [Summary of Apache Flink Dev List (covering February 2026)](#summary-of-apache-flink-dev-list-covering-february-2026) +* [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) + Review Comment: 1. I'm not sure it needs a TOC 2. If it does, I would limit the level depth ## docs/content/posts/2026-03-01-community-update.md: ## @@ -0,0 +1,145 @@ +--- +authors: +- davidrad: null + name: David Radley +date: "2026-03-01T08:00:00Z" +excerpt: Flink Community update for March 2026 +title: Flink Community Update - March'26 +aliases: +- /news/2026/03/01/community-update.html +--- + + + * [February 2026 overview](#february-2026-overview) + * [Flink related Blogs](#flink-related-blogs) + * [Summary of Apache Flink Dev List (covering February 2026)](#summary-of-apache-flink-dev-list-covering-february-2026) +* [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) + + +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. + +## February 2026 overview +This will summarise what has happened in the previous month (February). +* 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 go
Re: [PR] Community blog March 2026 [flink-web]
davidradl commented on PR #832: URL: https://github.com/apache/flink-web/pull/832#issuecomment-4013072938 @rmoff fyi -- 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]
