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

Hi everyone, I raised a docs PR to improve and expand the Glossary page (issues.apache.org/jira/browse/FLINK-40282) github.com/apache/flink/pull/28863

Hi team, I would love to revive this PR and help get it merged. Could someone point out to me, against which version of Flink, do we introduce and add this type of enhancement.

issues.apache.org/jira/browse/FLINK-40551 issues.apache.org/jira/browse/FLINK-40132 issues.apache.org/jira/browse/FLINK-40571 issues.apache.org/jira/browse/FLINK-40132 issues.apache.org/jira/browse/FLINK-38770 Hi, team. There are some flaky test cases and blocker jiras, Would anyone be willing to fix them? Thanks a lot! CC: @rmetzger (who followed FLINK-38770 by the PR page) 2.4 RMs @Mika Naylor @오찬해 @Sumin Joo

added an integration to this channel: jenkins

Hi all, Raising this for discussion before pushing further on the linked PR. Problem: In the Flink CDC Iceberg pipeline connector, when an

UPDATE

changes the value of a partitioned column, the row ends up duplicated. The old partition retains a stale copy, while the new partition contains the updated row. The root cause is in `RowDataUtils#convertDataChangeEventToRowData`: every

UPDATE

is currently collapsed into a single after image row tagged as

RowKind.INSERT

, so no delete is emitted for the row's original partition. Since Iceberg equality deletes are partition scoped by design, the delete that gets written to the new partition cannot reach the stale row in the old partition. Compaction doesn't help either, since there is no delete marker for the stale row. This has been filed as FLINK-40640, with a proposed fix in PR #4536: split

UPDATE

handling into an explicit

DELETE

(before image) +

INSERT

(after image) pair, and have

IcebergWriter

write both. I've also added a regression test that reproduces the duplicate against the current main branch and passes with the change. No other tests are affected. This has also been running in our production CDC pipelines and has resolved the issue there without any regressions. One possible argument could be that this should be fixed on the Iceberg side. However, from what I understand, the issue is that Flink CDC is currently sending only an

INSERT

with the after image when running in upsert mode, which means the original row is never deleted. In that case, Iceberg cannot know that it needs to remove the row from the original partition. Also, recommending that users avoid having a column that can change as an Iceberg partition column doesn't seem like a practical workaround. There are many common business use cases where a frequently updated column can also be a meaningful partitioning column. Given the size and nature of the change, I wanted to check here first: does this require a FLIP, or would a Jira + PR + committer review be sufficient, given that this is a bug fix rather than a behavioral/design change? Also, if anyone is familiar with the Iceberg pipeline connector, could you please take a look at the PR? Thanks!

Hi committers/maintainers, could you please take a look at this PR and approve it if everything looks good? github.com/apache/flink-cdc/pull/4536

https://github.com/datafusion-contrib/StreamFusion This is a new flink native engine based on datafusion. Support most sql stream ing operator and performance is great

Hi, can the committers/maintainers take a look at this issue (issues.apache.org/jira/…/FLINK-40776) and the associated PR (github.com/apache/flink/pull/29375) for a quick perf fix for a SQL function. Thanks!

Hi committers/maintainers, I was testing fs-native and found 2 possible bugs issues.apache.org/jira/browse/FLINK-40942 issues.apache.org/jira/browse/FLINK-40943 already create a PR for both github.com/apache/flink/pull/29420 github.com/apache/flink/pull/29422 if you can take a look when you have time.. thanks

Hi , if I have multiple jobs in operator mode there all and end up with the same context URL, so how can I configure context path for different different JOBS? So is there any reverse proxy available? We are using flink operator in openshift cluster It is community driven operator

Hello committers/maintainers, This is a major bug that can cause duplicate data during Flink → Iceberg ingestion. The issue has already been fixed and merged, but the fix is currently available only in the 3.7.0-rc1 release. Would it be possible to backport this fix to the 3.6.x version as well? This could affect many users running the 3.6.x release. github.com/apache/flink-cdc/pull/4360

Hi, all ! The lilsts.apache.org is currently not working. Does anyone happen to know where I should contact regarding this?

Hello committers/maintainers, coud lyou take a look at github.com/apache/flink/pull/28498 (FLINK-20454)? It adds metadata support to debezium-avro-confluent. Reviews addressed, CI green. Thanks!

Hi， @Aleksandr Savonin cwiki.apache.org/confluence/…/…#… Could you help take a look this benchmark issue? Many thanks CC @Rui Fan @Mika Naylor @오찬해 @Sumin Joo

Hi @RocMarshal, would you please take a look at this: issues.apache.org/jira/browse/FLINK-41061 🙏

👋 I have a ticket and PR, that could use a review when someone gets a chance, open to any feedback or suggestions

Hi maintainers, we identified a resource leak (since Flink version

1.19

) on our production instance. I've filed the issue here issues.apache.org/jira/browse/FLINK-41090 and wanted to commit the fix from our fork to upstream: github.com/apache/flink/pull/29585. Please take a look!

Hi everyone Raised a PR for Issue. Please help with review gratitude thank you