From c4078ae737434a8674d240738e14c4ff2bcb23b9 Mon Sep 17 00:00:00 2001
From: yanjunli <allovertheword@163.com>
Date: Mon, 21 Aug 2017 13:28:58 +0800
Subject: [PATCH] =?UTF-8?q?=E5=B7=B2=E9=AA=8C=E8=AF=81=20=E5=90=8C?=
 =?UTF-8?q?=E6=AD=A5=E5=91=BD=E4=BB=A4=20=E8=B6=85=E5=A4=9A=E5=88=97?=
 =?UTF-8?q?=E7=BB=93=E6=9E=9C=E9=9B=86=E9=80=8F=E4=BC=A0=20=E8=B6=85?=
 =?UTF-8?q?=E5=A4=9A=E8=A1=8C=E7=BB=93=E6=9E=9C=E9=9B=86=E9=80=8F=E4=BC=A0?=
 =?UTF-8?q?.=20=E8=B6=85=E5=A4=A7=E5=88=97=E7=BB=93=E6=9E=9C=E9=9B=86?=
 =?UTF-8?q?=E9=80=8F=E4=BC=A0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/io/mycat/mycat2/tasks/BackendSynchronzationTask.java    | 1 +
 1 file changed, 1 insertion(+)

diff --git a/source/src/main/java/io/mycat/mycat2/tasks/BackendSynchronzationTask.java b/source/src/main/java/io/mycat/mycat2/tasks/BackendSynchronzationTask.java
index 5456a45..354a2ea 100644
--- a/source/src/main/java/io/mycat/mycat2/tasks/BackendSynchronzationTask.java
+++ b/source/src/main/java/io/mycat/mycat2/tasks/BackendSynchronzationTask.java
@@ -37,6 +37,7 @@ private void syncState(MySQLSession session) throws IOException {
         queryPacket.sql = session.isolation.getCmd() + session.autoCommit.getCmd() + session.isolation.getCmd();
         queryPacket.write(frontBuffer);
         frontBuffer.flip();
+        frontBuffer.readIndex = frontBuffer.writeIndex;
         session.writeToChannel(frontBuffer, session.backendChannel);
     }