直接close socket，解决TLS half-close policy报错问题 (#5240)

2026-11-04 00:30:15 +08:00 · 2024-08-29 12:47:50 +08:00
parent b060f46ccf
commit ff82fd6532
1 changed files with 0 additions and 10 deletions
--- 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) {