mirror/dble
1
0
Fork 0
mirror of https://github.com/actiontech/dble.git synced 2026-01-05 12:20:19 -06:00
Code Issues Packages Projects Releases Wiki Activity

fix load data lost connection inner 2039

Browse Source
This commit is contained in:
lin
2022-12-09 10:17:30 +08:00
parent b38917ec08
commit 9367f44aa8
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

@@ -414,7 +414,6 @@ public class MultiNodeLoadDataHandler extends MultiNodeHandler implements LoadDa
errorCount += ok.getWarningCount();
}
dnSet.add(rrn.getName());
removeNode(rrn.getName());
transformOkPackage(ok, shardingService);
if (packet == null)
packet = ok;
@@ -605,6 +604,7 @@ public class MultiNodeLoadDataHandler extends MultiNodeHandler implements LoadDa
RouteResultsetNode rrn = (RouteResultsetNode) ((MySQLResponseService) service).getAttachment();
RowDataPacket rowDataPkg = new RowDataPacket(3);
rowDataPkg.read(row);
removeNode(rrn.getName());
Map<String, List<String>> warnings = LoadDataBatch.getInstance().getWarnings();
String name = rrn.getName();
if (!warnings.containsKey(name)) {