rollback fix npe inner 2191

2026-01-05 12:20:19 -06:00 · 2024-03-22 15:18:47 +08:00
parent ace71d864e
commit 57032f2eda
1 changed files with 1 additions and 1 deletions
--- 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 class MultiNodeLoadDataHandler extends MultiNodeHandler implements LoadDa
                    }
                    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()) {