cygnusdark opened a new issue, #149: URL: https://github.com/apache/doris-flink-connector/issues/149
### Search before asking - [X] I had searched in the [issues](https://github.com/apache/incubator-doris/issues?q=is%3Aissue) and found no similar issues. ### Version 1.4.0 ### What's Wrong? CDCTools job cannot restart from previous checkpoint/savepoint when multiple tables in sync. ### What You Expected? The job should be able to use previous checkpoint/savepoint to restart. ### How to Reproduce? To reproduce, sync multiple tables, for example: --including-tables test|test2|test_clone|test_clone2 The reason is that Flink is a stateful application, and it is recommended by official that each stateful operator should have a unique uid. I fixed this issue by using table name as the uid of its associated sink operators. ### Anything Else? _No response_ ### Are you willing to submit PR? - [X] Yes I am willing to submit a PR! ### Code of Conduct - [X] I agree to follow this project's [Code of Conduct](https://www.apache.org/foundation/policies/conduct) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org For additional commands, e-mail: commits-h...@doris.apache.org
