Jia Fan

You upgrade flink to 1.14, but lost flink 1.13 support feature. Maybe you should extract some public methods, and then support different flink versions through different modules, the same as...

> Is there a case where we have multiple sources in the single pipeline? This causes the COMPLETED_POINT_TYPE to be triggered when a single source completes good point, I will...

@ashulin Temporary solution to ensure that the task can run normally, and the fine-grained part of the task completed logic will be resolved in the future.

I think method 1 can only support replace parameter in env. But not use `-i`, use `-p` or other. Method 2 is good for replace the placeholder.

Hi, can you add some test case for this? Thanks.

Hi, e2e same like have some problem. 

The test case not passed, please fix it. Thanks.

Hi ,please fix ci first, thanks.

Seem like the jdbc e2e failed.

Maybe you can use config to set some e2e test case use disruptor queue, to test disruptor queue in zeta.