diff --git a/driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/socket/BioSocketChannel.java b/driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/socket/BioSocketChannel.java index a36e7f3c..1bdb876f 100644 --- a/driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/socket/BioSocketChannel.java +++ b/driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/socket/BioSocketChannel.java @@ -167,16 +167,6 @@ public class BioSocketChannel implements SocketChannel { public void close() { Socket socket = this.socket; if (socket != null) { - try { - socket.shutdownInput(); - } catch (IOException e) { - // Ignore, could not do anymore - } - try { - socket.shutdownOutput(); - } catch (IOException e) { - // Ignore, could not do anymore - } try { socket.close(); } catch (IOException e) {