ckl750 opened a new issue, #8859: URL: https://github.com/apache/seatunnel/issues/8859
### 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 In SeaTunnel Engine Separated Cluster Mode, when the active master node switches, if some tasks of a job have a FINISHED status, the CheckpointCoordinator cannot restore normally, resulting in the job's status being displayed as RUNNING but the data never being written to the target table. ### SeaTunnel Version 2.3.8 ### SeaTunnel Config ```conf { "env" : { "job.mode" : "STREAMING", "parallelism" : "3" "checkpoint.interval" : "10000" }, "source" : [ { "base-url" : "jdbc:mysql://localhost:13306/test?useUnicode=true&serverTimezone=Asia/Shanghai&characterEncoding=UTF-8&useSSL=false", "password" : "******", "startup.mode" : "INITIAL", "debezium" : { "event.processing.failure.handling.mode" : "warn" }, "table-names" : [ "test.ckl_test_text" ], "result_table_name" : "ckl_test_all_fields4_aliais", "database-names" : [ "test" ], "plugin_name" : "MYSQL-CDC", "username" : "bigdata_test" } ], "transform" : [ { "query" : "select ID ID, C_VARCHART2 C_VARCHART2,C_CLOB C_CLOB from ckl_test_all_fields4_aliais", "source_table_name" : [ "ckl_test_all_fields4_aliais" ], "result_table_name" : "ckl_test_all_fields4mapping_table", "plugin_name" : "sql" } ], "sink" : [ { "schema" : "BIGDATA", "primary_keys" : [ "ID" ], "max_retries" : 3, "schema_save_mode" : "ERROR_WHEN_SCHEMA_NOT_EXIST", "source_table_name" : [ "ckl_test_all_fields4mapping_table" ], "max_commit_attempts" : 3, "plugin_name" : "jdbc", "url" : "jdbc:oracle:thin:@//localhost:1521/dxdata", "is_exactly_once" : false, "password" : "******", "database" : "", "xa_data_source_class_name" : "oracle.jdbc.xa.OracleXADataSource", "driver" : "oracle.jdbc.OracleDriver", "data_save_mode" : "APPEND_DATA", "generate_sink_sql" : true, "user" : "bigdata", "table" : "CKL_TEST_CLOB" } ] } ``` ### Running Command ```shell - ``` ### Error Exception ```log There is not any errors in the log ``` ### Zeta or Flink or Spark Version _No response_ ### Java or Scala Version java 1.8 ### Screenshots _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...@seatunnel.apache.org.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
