Browse Source

fix bug: wrong quit command implementation (#2554)

jianqingdu 5 years ago
parent
commit
4fc7e5f7d9

+ 0 - 3
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();
     }