EricJoy2048 opened a new issue, #4115: URL: https://github.com/apache/incubator-seatunnel/issues/4115
### Search before asking - [X] I had searched in the [issues](https://github.com/apache/incubator-seatunnel/issues?q=is%3Aissue+label%3A%22bug%22) and found no similar issues. ### What happened I run the IT `ClusterFaultToleranceIT.testBatchJobRestoreIn2NodeMasterDown` there only `5800` rows in the files and the job status is `Finished`. ``` 2023-02-13 13:41:20,064 INFO org.apache.seatunnel.engine.server.dag.physical.SubPlan - Job testBatchJobRestoreIn2NodeMasterDown (677388726761947138), Pipeline: [(1/1)] end with state FINISHED 2023-02-13 13:41:20,067 INFO org.apache.seatunnel.engine.server.checkpoint.CheckpointCoordinator - start clean pending checkpoint cause Pipeline turn to end state. 2023-02-13 13:41:20,221 INFO org.apache.seatunnel.engine.server.service.slot.DefaultSlotService - received slot release request, jobID: 677388726761947138, slot: SlotProfile{worker=[localhost]:5802, slotID=4, ownerJobID=677388726761947138, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='1413919c-b844-4ec5-a69b-0cef90394f2c'} 2023-02-13 13:41:20,226 INFO org.apache.seatunnel.engine.server.service.slot.DefaultSlotService - received slot release request, jobID: 677388726761947138, slot: SlotProfile{worker=[localhost]:5802, slotID=2, ownerJobID=677388726761947138, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='1413919c-b844-4ec5-a69b-0cef90394f2c'} 2023-02-13 13:41:20,226 INFO org.apache.seatunnel.engine.server.service.slot.DefaultSlotService - received slot release request, jobID: 677388726761947138, slot: SlotProfile{worker=[localhost]:5802, slotID=3, ownerJobID=677388726761947138, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='1413919c-b844-4ec5-a69b-0cef90394f2c'} 2023-02-13 13:41:20,226 INFO org.apache.seatunnel.engine.server.service.slot.DefaultSlotService - received slot release request, jobID: 677388726761947138, slot: SlotProfile{worker=[localhost]:5802, slotID=5, ownerJobID=677388726761947138, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='1413919c-b844-4ec5-a69b-0cef90394f2c'} 2023-02-13 13:41:20,226 INFO org.apache.seatunnel.engine.server.service.slot.DefaultSlotService - received slot release request, jobID: 677388726761947138, slot: SlotProfile{worker=[localhost]:5802, slotID=6, ownerJobID=677388726761947138, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='1413919c-b844-4ec5-a69b-0cef90394f2c'} 2023-02-13 13:41:20,226 INFO org.apache.seatunnel.engine.server.service.slot.DefaultSlotService - received slot release request, jobID: 677388726761947138, slot: SlotProfile{worker=[localhost]:5802, slotID=8, ownerJobID=677388726761947138, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='1413919c-b844-4ec5-a69b-0cef90394f2c'} 2023-02-13 13:41:20,226 INFO org.apache.seatunnel.engine.server.service.slot.DefaultSlotService - received slot release request, jobID: 677388726761947138, slot: SlotProfile{worker=[localhost]:5802, slotID=1, ownerJobID=677388726761947138, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='1413919c-b844-4ec5-a69b-0cef90394f2c'} 2023-02-13 13:41:20,226 INFO org.apache.seatunnel.engine.server.service.slot.DefaultSlotService - received slot release request, jobID: 677388726761947138, slot: SlotProfile{worker=[localhost]:5802, slotID=7, ownerJobID=677388726761947138, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='1413919c-b844-4ec5-a69b-0cef90394f2c'} 2023-02-13 13:41:20,232 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalPlan - Job testBatchJobRestoreIn2NodeMasterDown (677388726761947138) end with state FINISHED 2023-02-13 13:41:20,248 INFO org.apache.seatunnel.engine.client.job.ClientJobProxy - Job (677388726761947138) end with state FINISHED 5800 org.opentest4j.AssertionFailedError: Expected :6000 Actual :5800 <Click to see difference> ``` ### SeaTunnel Version dev ### SeaTunnel Config ```conf IT: `ClusterFaultToleranceIT.testBatchJobRestoreIn2NodeMasterDown` ``` ### Running Command ```shell * ``` ### Error Exception ```log * ``` ### Flink or Spark Version _No response_ ### 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]
