mirror/dble
1
0
Fork 0
mirror of https://github.com/actiontech/dble.git synced 2026-05-04 05:20:48 -05: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 GitHub
parent 2387875896 274ea02bf8
commit c7fa5c172b
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/com/actiontech/dble/backend/mysql/nio/handler/MultiNodeLoadDataHandler.java
+1 -1
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)) {