-
Notifications
You must be signed in to change notification settings - Fork 45
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Support Flink 2 (and preview) #126
Comments
I am happy to work on this. @kzarzycki |
Sure @davidradl ! If you needed help with lineage APIs and/or OpenLineage, our colleagues from Getindata actually implemented it, like @pawel-big-lebowski :) |
sounds good. I will see how the Kafka connector plays out, in terms of java levels. before looking at this. |
@davidradl I think we should be ready soon with the first version of job listener that converts Flink lineage into OpenLineage events. We'll bring more details during Flink Forward talk https://www.flink-forward.org/berlin-2024/agenda#data-lineage-for-apache-flink-with-openlineage |
sounds good - I am attending so will come along and say hello! |
There may be a different java version. Also there is a Flink lineage tracing capability that we may want to take advantage of. The dev list has a post proposing lots of deliverables for v1 pre lineage and V1 with lineage and V2 Kafka connector.
The text was updated successfully, but these errors were encountered: