diff --git a/client-adapter/common/src/main/java/com/alibaba/otter/canal/client/adapter/support/Util.java b/client-adapter/common/src/main/java/com/alibaba/otter/canal/client/adapter/support/Util.java index e94033dd..34549be4 100644 --- a/client-adapter/common/src/main/java/com/alibaba/otter/canal/client/adapter/support/Util.java +++ b/client-adapter/common/src/main/java/com/alibaba/otter/canal/client/adapter/support/Util.java @@ -44,6 +44,8 @@ public class Util { if ("postgresql".equals(druidDataSource.getDbType())) { conn.setAutoCommit(false); stmt.setFetchSize(1000); + } else if ("sqlserver".equals(druidDataSource.getDbType())) { + stmt.setFetchSize(100); } else { stmt.setFetchSize(Integer.MIN_VALUE); }