Hi, christopher,
I think there is already about the ExecutionConfig for new Sink API in
the FLIP-287[1]. What we actually need is a read-only ExecutionConfig for
Source API and Sink API.
Maybe we could continue to discuss this topic under FLIP-287.
Best,
Hang
[1]
https://cwiki.apache.org/conflue
I agree with you. It's quite useful to access the ExecutionConfig in
Source API. When I develop the flink-connector-pulsar. The only
configuration that I can't access is the checkpoint configure which is
defined in ExecutionConfig. I can switch the behavior automatically by
the checkpoint switch. S
Hello,
I'm trying to develop Flink connectors to NATS using the new FLIP-27 and
FLIP-143 APIs. The scaffolding is more complicated than the old
SourceFunction and SinkFunction, but not terrible. However I can't figure
out how to access the ExecutionConfig under these new APIs. This was
possible in
