From 4fc7e5f7d950c9d4f9679a0c4f6d64003a8c9bed Mon Sep 17 00:00:00 2001 From: jianqingdu Date: Fri, 28 Feb 2020 10:52:35 +0800 Subject: [PATCH] fix bug: wrong quit command implementation (#2554) --- .../parse/driver/mysql/packets/client/QuitCommandPacket.java | 3 --- 1 file changed, 3 deletions(-) diff --git a/driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/packets/client/QuitCommandPacket.java b/driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/packets/client/QuitCommandPacket.java index 113c1965..dfd51de0 100644 --- a/driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/packets/client/QuitCommandPacket.java +++ b/driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/packets/client/QuitCommandPacket.java @@ -13,8 +13,6 @@ import com.alibaba.otter.canal.parse.driver.mysql.packets.CommandPacket; */ public class QuitCommandPacket extends CommandPacket { - public static final byte[] QUIT = new byte[] { 1, 0, 0, 0, 1 }; - public QuitCommandPacket(){ setCommand((byte) 0x01); } @@ -28,7 +26,6 @@ public class QuitCommandPacket extends CommandPacket { public byte[] toBytes() throws IOException { ByteArrayOutputStream out = new ByteArrayOutputStream(); out.write(getCommand()); - out.write(QUIT); return out.toByteArray(); }