Hello 👋, I have a PR that addresses FLINK-30975 (“AWS SDK V2 Support for Flink’s S3 Hadoop FileSystem”)

Hello 👋 I have a PR that address FLINK-39556 (Make file path optional in COMPILE PLAN to return plan inline as a result set). I'm hoping to get a review. Thanks in advance!

Hello Team, I have opened a [DISCUSS] thread for supporting rocksdb's AssociativeMergeOperator using Java via JNI, and leverage that to build associative state variables. Currently, the state variables are not leveraging the full power of rocksdb and rely on read-modify-write on every write calls. This can be a bottleneck for write-heavy workloads. I have the prototype implementation in FrocksDB and corresponding changers in Flink in my forks, I am looking for help from fellow members to review the proposal. Discussion Thread: https://lists.apache.org/thread/w0llnl1p25h282g9kkc6cng6blbb7nmh JIRAs: 1. Add support for Java based AssociativeMergeOperator via JNI 2. Support ReducingMergeState and AggregatingMergeState backed by Java based associative merge operators RocksDB AssociativeMergeOperator Please help review and +1 the proposal. 🙏

Hello team, I have created a Jira and PR for a RocksDB shared cache memory leak. Analysis and reproduction steps are available on the Jira description. Jira: https://issues.apache.org/jira/plugins/servlet/mobile#issue/FLINK-39753 PR: https://github.com/apache/flink/pull/28251 Would appreciate review here. Thank you.

Hi, team. The Voting email for Flink 2.3.0 release candidate #2 was sent out. https://lists.apache.org/thread/d4jcs498vxgnq85gd37tf96xbbby9hdb Looking forward to your reivew. Thank you very much! CC @Hao Li @David Anderson

hello team, I've a PR that's approved but pending merge, would appreciate if someone can help: • https://github.com/apache/flink/pull/28202 • https://github.com/apache/flink/pull/28332 Thank you very much!

Hey all 👋 — sorry if I didn’t follow the correct process here. I have a fairly simple PR that aims to provide a configuration option for setting the ForSt checkpoint transfer thread count. • https://github.com/apache/flink/pull/28373

Hi, team. I noticed the Nightly(beta) CI @Sergey Nuyanzin re-triggered has passed successfully.[1] After fixing and migrating the patches[2] listed below, the stability of Nightly(beta) CI has improved noticeably. That said, I have identified several new flaky test cases[3][4][5][6]. These issues are less likely to cause frequent CI failures compared to before. If you think it is still too early to proceed with the release based on the release-2.3 branch, we(2.3 release RMs) will keep working on migrating patches for the remaining flaky tests. Please let us know your thoughts. Appreciate any feedback. [1] https://github.com/apache/flink/actions/workflows/nightly.yml?query=branch%3Arelease-0.10+branch%3Arelease-2.3 [2] https://github.com/apache/flink/commits/release-2.3?from=7b0bd813bbe8550163dc3f1a1e4b0afd2ad00726&since=2026-06-04&until=2026-06-14 [3] https://issues.apache.org/jira/browse/FLINK-39931 [4] https://issues.apache.org/jira/browse/FLINK-39930 [5] https://issues.apache.org/jira/browse/FLINK-39929 [6] https://issues.apache.org/jira/browse/FLINK-39921 CC @Sergey Nuyanzin @David Anderson @Martijn Visser

Hello team, I have created a Jira issue and a PR to fix Jemalloc misconfiguration that causes higher memory utilisation and sometimes OOMKills. This primarily impact pods with CPU limit configured to be lower than host machine's CPU count. In my verification, the fix reduces average process memory usage by 13.7% and improves average throughput by 4.4 %. The Jira and PR have reproduction and verification details. PR: https://github.com/apache/flink-docker/pull/266 Jira: https://issues.apache.org/jira/browse/FLINK-39924 Would appreciate reviews here. I will follow up with back-port PRs if approved. Thank you

@RocMarshal thank you for stabilizing. Given the fact that nightly is green for commits including non tests changes we need another RC

Hi Team, We had to make our flink env hardened to use the desired security.ssl.algorithms and security.ssl.protocol in the internal and rest communication. Everything worked fine till we had to use a cipher which is not in the java defaults and it truned out that protocols and ciphers are not set everywhere. So, I'd created a Jira ticket related to use the same SSL protcol and algorithms on all the flink services and all clients . I have the fix downstream, but I think it would be useful to submit to the upstream as well. Please take a look and Thank you! Br, Jozsef

Let's all appreciate the moment that for

master

for the first time in what seems like forever, we have a fully passed CI run for all the nightly tests - And try to keep it up 😅

Hi Team, Just wanted to ask is there any release planned for flink-prometheus-connector for flink 2.x?

Hi Team, I have a fix for issues.apache.org/jira/browse/FLINK-38023 (State Restoration fails when using GenericRecord with new Avro schema) in github.com/apache/flink/pull/28161 I am unable to assign the jira to myself, but the PR is ready. Please review this PR. Thanks

Does anyone know why issues.apache.org or anything specific to this project, is unreachable (for me)?

Hi team, I've recently opened two PRs related to unaligned checkpoints and would appreciate your review: 1. Introduce

SupportsSoftBackpressure

for operators: This aims to prevent the mailbox thread from being blocked when an async operator is full.

AsyncWaitOperator

implements this interface. PR-28305 2. Support unaligned checkpoints on pointwise edges: This includes an opt-in switch and channel state recovery, even when parallelism and/or distribution patterns change. PR-28523 Thanks in advance for your time!

github.com/apache/…/85401763806 Hi, team. The JDBC release is blocked by this issue. I'd appreciate it if someone help check it.

Hi, team. The Flink connector JDBC v3.4.0 & v4.1.0 are in voting. I'd be appreciated for your verification or comments. lists.apache.org/thread/szy4cjo80p47ho6bfnf03goflx6mrhdd lists.apache.org/thread/m936m36or3zjgccnykn9x32sk6tw2rdx

Good morning all! I just made a request to get my jira account set up, so if somebody could try and approve me I'll open a PR for this. I'm building out a Flink accelerator on top of DataFusion called [StreamFusion](github.com/datafusion-contrib/StreamFusion/tree/main). In order to do this, I'm hoping to add an extensible SQL planner api based on inspiration from what spark does (you specify a class in a runtime jar to add custom planning rules). The change is here if anybody has any initial feedback before I file an official merge request, thank you! github.com/jordepic/flink/commit/e0ca57a3b67f…

Hi, team. The voting emails of JDBC connector release candidates #4 were sent out. I'd apprecate it if you could help verify ! lists.apache.org/thread/vo0wwtwrr263drnt1m62n0cj6wpr7dh1 lists.apache.org/thread/dtps7w4hh7b2fc31rtd4cc7l2x0kt4pc CC @Sergey Nuyanzin @Ferenc Csaky @Leonard Xu @Rui Fan

Hey all 👋 — sorry if this is the incorrect channel. I have a small PR open that adds a configuration option. It’s been reviewed by the community, does anyone know what the next steps would be? Ty! github.com/apache/flink/pull/28373

The binding votes(JDBC connector v3.4.0) are still insufficient for this release. Could any PMC member please help review and cast a vote? Thanks! https://lists.apache.org/thread/dtps7w4hh7b2fc31rtd4cc7l2x0kt4pc

Hey all, new to Flink coming from Apache Flume's dormancy, but we use OpenSearch 3 and was looking at the flink-connector-opensearch - but I am not seeing the OpenSearch3 builds yet in maven central. dumb question, is there a release pattern for the connectors or anyone have insights on when the OpenSearch3 connector would be released?

Hey all 👋 — I ran into issues.apache.org/jira/browse/FLINK-37686 in production and took the liberty to attempt to open a PR with a fix. Please let me know if you have and feedback, ty! github.com/apache/flink/pull/28801

hello team, I've a small PR, which remove unused mode in cli, would appreciate if someone can help: • https://github.com/apache/flink-cdc/pull/4493 Thanks!

Hi, I have a PR, looking for next steps or any feedback

Hi, could someone help take another look at this PR when available? github.com/apache/flink/pull/28478 The latest Azure build is green, and I revalidated it locally with: ./mvnw -pl flink-core-api -Dtest=MemorySizeTest test MemorySizeTest passed with 17 tests, 0 failures, 0 errors, and 0 skipped. Thanks!

This PR has been open since Feb and is still relevant I think: github.com/apache/flink/pull/27700

Hi 👋 Can I get assigned to issues.apache.org/jira/browse/FLINK-39137 (AWS Connector: Add configurable delay between non-empty GetRecords calls in Kinesis source)? I took the liberty of posting the PR already: github.com/apache/flink-connector-aws/pull/254

Hi, anyone would be able to take a look at the open PR for issues.apache.org/jira/browse/FLINK-40037 PR is ready to be merged github.com/apache/flink/pull/28611