diff --git a/chunjun-connectors/chunjun-connector-doris/src/main/java/com/dtstack/chunjun/connector/doris/options/DorisConf.java b/chunjun-connectors/chunjun-connector-doris/src/main/java/com/dtstack/chunjun/connector/doris/options/DorisConf.java index ccfb3d5f13..1c4951e09d 100644 --- a/chunjun-connectors/chunjun-connector-doris/src/main/java/com/dtstack/chunjun/connector/doris/options/DorisConf.java +++ b/chunjun-connectors/chunjun-connector-doris/src/main/java/com/dtstack/chunjun/connector/doris/options/DorisConf.java @@ -180,6 +180,10 @@ public JdbcConf setToJdbcConf() { jdbcConf.setJdbcUrl(url); jdbcConf.setPassword(password); jdbcConf.setUsername(username); + + jdbcConf.setBatchSize(this.getBatchSize()); + jdbcConf.setFlushIntervalMills(this.getFlushIntervalMills()); + return jdbcConf; } }