mirror/dble
1
0
Fork 0
mirror of https://github.com/actiontech/dble.git synced 2026-01-04 03:40:13 -06:00
Code Issues Packages Projects Releases Wiki Activity

fix an error that occurred during commit during load data inner 2191

Browse Source
This commit is contained in:
ylz
2023-12-01 16:27:04 +08:00
parent 622ae1e5f4
commit 06bcb58b56
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/java/com/actiontech/dble/backend/mysql/nio/handler/MultiNodeLoadDataHandler.java
View File

@@ -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()) {