From 57032f2eda239dcf3bef04803233d28e6443ca66 Mon Sep 17 00:00:00 2001 From: ylz Date: Fri, 22 Mar 2024 15:18:47 +0800 Subject: [PATCH] rollback fix npe inner 2191 --- .../backend/mysql/nio/handler/MultiNodeLoadDataHandler.java | 2 +- 1 file changed, 1 insertion(+), 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 index bb03bea38..e5845651b 100644 --- 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()) {