From 53a4798b3b083b0aa67cba7806782d9feaf88d0d Mon Sep 17 00:00:00 2001
From: ylz <yuanlinzhu1995@gmail.com>
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 bb03bea38a..e5845651b3 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 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()) {