I have solved this problem because when I created the Flink local environment
in test, I did not add the configuration
`execution.checkpointing.checkpoints-after-tasks-finish.enabled=true`.
Jianyun Zhao
2021-09-15
2021年9月14日 14:52，赵 建云
mailto:zhaojianyu...@outlook.com>> 写道：
Hi flink
connector.
Hope this helps eliminate some concerns here.
The Flink community might be a bit unresponsive in the next couple of
days because of Christmas and New Year. Beginning of January the discussion
should see a couple of additional comments.
Cheers,
Till
On Wed, Dec 23, 2020 at 10:37 AM 赵 建云
We are now done with the Flink Pulsar connector. It is ready to be merged.
Now our plan is
1. merge Source and Sink based on Function, because it has been verified by
users and is reliable.
2. Next is to merge the DynamicTable feature. table implementation depends
on Step 1.
3. merge
