Merge pull request #3850 from actiontech/2191

fix an error that occurred during commit during load data inner 2191
actiontech · Dec 14, 2023 · 26dd566 · 26dd566
2 parents 622ae1e + 06bcb58
commit 26dd566
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/java/com/actiontech/dble/backend/mysql/nio/handler/MultiNodeLoadDataHandler.java b/src/main/java/com/actiontech/dble/backend/mysql/nio/handler/MultiNodeLoadDataHandler.java
@@ -424,11 +424,11 @@ public void okResponse(byte[] data, AbstractService service) {
                     }
                     String filePath = rrn.getLoadData().getFileName();
                     LoadDataBatch.getInstance().setFileName(filePath);
-                    handlerCommit(rrn);
                     FileUtils.deleteFile(filePath);
                     rrn.setLoadDataRrnStatus((byte) 1);
                     decrementToZero((MySQLResponseService) service);
                     if (unResponseRrns.size() != 0) {
+                        handlerCommit(rrn);
                         return;
                     }
                     if (rrs.isGlobalTable()) {