Hi flink devs,

I'd like to start a discussion thread for FLIP-287[1].
This comes from an offline discussion with @Lijie Wang, from FLIP-239[2]
specially for the sink[3].

Basically to expose the ExecutionConfig and JobId on SinkV2#InitContext.
This  changes are necessary to correct migrate the current sinks to SinkV2
like JdbcSink, KafkaTableSink and so on, that relies on RuntimeContext

Comments are welcome!
Thanks,

[1]
https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=240880853
[2]
https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=217386271
[3] https://issues.apache.org/jira/browse/FLINK-25421

Reply via email to