Re: 退订

2023-04-02 Thread Weihua Hu
Hi, you need send email to user-unsubscr...@flink.apache.org with any contents or subject [1] https://flink.apache.org/community.html#how-to-subscribe-to-a-mailing-list Best, Weihua On Fri, Mar 31, 2023 at 4:02 PM z wrote: > >

退订

2023-04-02 Thread
退订

Re: 退订

2023-04-02 Thread Weihua Hu
Hi, you need send email to user-unsubscr...@flink.apache.org with any contents or subject [1] https://flink.apache.org/community.html#how-to-subscribe-to-a-mailing-list Best, Weihua > On Apr 3, 2023, at 11:15, 风 <919417...@qq.com> wrote: > > 退订

Access ExecutionConfig from new Source and Sink API

2023-04-02 Thread Christopher Lee
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

Re: Access ExecutionConfig from new Source and Sink API

2023-04-02 Thread Yufan Sheng
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

Re: Access ExecutionConfig from new Source and Sink API

2023-04-02 Thread Hang Ruan
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