MOBIN-F opened a new pull request, #3643: URL: https://github.com/apache/flink-cdc/pull/3643
hi @Mrart ,I merged your [PR](https://github.com/apache/flink-cdc/pull/3599) and tested it, but found some problem,i fixed it and added some tests. flink-cdc-pipeline is a great feature, but currently only supports yarn-session in yarn. I think the cdc-community should support application mode as soon as possible so that users can promote the use of pipeline features within the company. main changes of this PR are: 1. Added CliExecutor#main method as the program entry of application mode, because in application mode, the main method runs in the cluster 2. org.apache.flink.core.fs.Path replaces java.nio.file.Path, because additionalJars may be on the remote hdfs or oss 3. MysqlE2eWithYarnApplicationITCase is the flink yarn application test class, which will start yarnminicluster to submit flink jobs @yuxiqian @leonardBang @Mrart Can you help review this PR? Thank you～ -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
