diff --git a/src/main/server/com/baidu/hsb/mysql/bio/executor/SingleNodeExecutor.java b/src/main/server/com/baidu/hsb/mysql/bio/executor/SingleNodeExecutor.java index 0d91397..faff536 100644 --- a/src/main/server/com/baidu/hsb/mysql/bio/executor/SingleNodeExecutor.java +++ b/src/main/server/com/baidu/hsb/mysql/bio/executor/SingleNodeExecutor.java @@ -299,7 +299,7 @@ private void handleRowData(RouteResultsetNode rrn, BlockingSession ss, MySQLChan final ServerConnection sc = ss.getSource(); this.packetId = id; BinaryPacket bin = null; - int size = 0; +// int size = 0; try { for (;;) { bin = mc.receive(); @@ -328,11 +328,11 @@ private void handleRowData(RouteResultsetNode rrn, BlockingSession ss, MySQLChan default: bin.packetId = ++packetId;// ROWS bb = bin.write(bb, sc); - size += bin.packetLength; - if (size > RECEIVE_CHUNK_SIZE) { - handleNext(rrn, ss, mc, bb, packetId); - return; - } +// size += bin.packetLength; +// if (size > RECEIVE_CHUNK_SIZE) { +// handleNext(rrn, ss, mc, bb, packetId); +// return; +// } } } } catch (IOException e) {