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

fix load data lost connection inner 2039

Browse Source 
fix load data lost connection inner 2039
This commit is contained in:
ylinzhu
2022-12-09 14:00:25 +08:00
committed by lin
parent e54893839a
commit bcf10abe99
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

@@ -413,7 +413,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;
@@ -604,6 +603,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)) {