Browse Source

fixed unused code

七锋 7 years ago
parent
commit
7b52568575

+ 0 - 2
driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/socket/BioSocketChannelPool.java

@@ -16,8 +16,6 @@ public abstract class BioSocketChannelPool {
         socket.setKeepAlive(true);
         socket.setReuseAddress(true);
         socket.connect(address, BioSocketChannel.DEFAULT_CONNECT_TIMEOUT);
-        System.out.println(socket.getReceiveBufferSize());
-        System.out.println(socket.getSendBufferSize());
         return new BioSocketChannel(socket);
     }
 

+ 0 - 3
parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/dbsync/DirectLogFetcher.java

@@ -64,9 +64,6 @@ public class DirectLogFetcher extends LogFetcher {
         if ("1".equals(dbsemi)) {
             issemi = true;
         }
-        // 和mysql driver一样,提供buffer机制,提升读取binlog速度
-        // this.input = new
-        // BufferedInputStream(channel.socket().getInputStream(), 16384);
     }
 
     /**