Hello Flink devs,

I needed support for FLINK-39219
<https://issues.apache.org/jira/browse/FLINK-39219>. Currently,
DataStream-based providers (e.g. Apache Paimon) cannot have their
LineageVertex extracted for FLIP-314 lineage events.

This is a blocker for us at Yelp. We are integrating Lineage with Apache
Paimon using FLIP-314 (implementing LineageVertexProvider), and this change
is required for it to work (Issue Link
<https://github.com/apache/paimon/issues/7306>). While investigating the
issue, I created a PR with a proposed fix: (PR Link
<https://github.com/apache/flink/pull/27727>). The change is small and
scoped; it touches only CommonExecTableSourceScan and CommonExecSink in the
table planner.

Would appreciate any guidance or help in getting this reviewed and moved
forward. Happy to make adjustments based on feedback.

Jaskaran

Reply via email to