Skip to content
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.

Sign up for GitHub

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

Jump to bottom

Support for new Flink Source and Sink inferfaces #3536

Open
jedrz opened this issue Sep 16, 2022 · 0 comments
Open

Support for new Flink Source and Sink inferfaces #3536

jedrz opened this issue Sep 16, 2022 · 0 comments
Labels
enhancement

Comments

@jedrz
Copy link
Contributor

jedrz commented Sep 16, 2022 •
edited

Flink 1.11 introduced new Source and Sink instead of the SourceFunction and SinkFunction interfaces. Currently Nussknacker easily supports only old interfaces via BasicFlinkSource and BasicFlinkSink. New Flink Source and Sink can be used only while preparing custom DataStream along with low-level stuff like watermarks, operator ids, etc. using Nussknacker FlinkSource and FlinkSink. In addition, some connectors have been already switched to new the API.

More details how to implement a source using the new interface: https://nightlies.apache.org/flink/flink-docs-stable/docs/dev/datastream/sources/#data-source-concepts
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Assignees
No one assigned
Labels
enhancement
Projects
None yet
Milestone
No milestone
Development

No branches or pull requests
1 participant
@jedrz