wangjunjie-lnnf opened a new issue, #7400: URL: https://github.com/apache/seatunnel/issues/7400
### Search before asking - [X] I had searched in the [issues](https://github.com/apache/seatunnel/issues?q=is%3Aissue+label%3A%22bug%22) and found no similar issues. ### What happened same with https://github.com/apache/seatunnel/issues/6789, MysqlCdc stop.mode not work, 跟这个一样，长时间没人解决已经close。I can help fix and maintain the project, but I never join some open source project, don't known how to start, if you need someone to help maintain, please contact me. ### SeaTunnel Version 2.3.6 ### SeaTunnel Config ```conf env { parallelism = 2 job.mode = "STREAMING" checkpoint.interval = 2000 } source { MySQL-CDC { base-url = "jdbc:mysql://localhost:3306/test" username = "root" password = "" table-names = ["test.test_001"] startup.mode = "initial" stop.mode = "latest" exactly_once = true } } sink { Console { } } ``` ### Running Command ```shell none ``` ### Error Exception ```log none ``` ### Zeta or Flink or Spark Version problem is simple, see code below ``` package org.apache.seatunnel.connectors.seatunnel.cdc.mysql.source.reader.fetch.binlog; public class MySqlBinlogFetchTask implements FetchTask<SourceSplitBase> { @Override public void execute(FetchTask.Context context) throws Exception { // this line show create object of MySqlBinlogSplitReadTask not MySqlStreamingChangeEventSource, // MySqlStreamingChangeEventSource belongs debezium, it never check stop.mode // 这行代码应该创建MySqlBinlogSplitReadTask而不是MySqlStreamingChangeEventSource， // MySqlStreamingChangeEventSource来自debezium，不会检查stop.mode MySqlStreamingChangeEventSource mySqlStreamingChangeEventSource = new MySqlStreamingChangeEventSource(...); ........ } } ``` ### Java or Scala Version _No response_ ### Screenshots _No response_ ### Are you willing to submit PR? - [ ] 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
