From a50795d5621d0ff276f5d7ca2391ed62aa72361f Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E7=99=BE=E5=B2=81?= Date: Sat, 3 Sep 2022 15:03:50 +0800 Subject: [PATCH 1/2] Update DorisConf.java MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit fix the bug issue for https://github.com/DTStack/chunjun/issues/1171，By the way， has add an other lacked param ‘FlushIntervalMills’ for DorisConf Signed-off-by: 百岁 --- .../dtstack/chunjun/connector/doris/options/DorisConf.java | 4 ++++ 1 file changed, 4 insertions(+) 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..6d64f75b58 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; } } From efaf46b279882b33ac9bfcb75bc2ced1cd2be6d8 Mon Sep 17 00:00:00 2001 From: mozhenghua Date: Sat, 3 Sep 2022 15:11:25 +0800 Subject: [PATCH 2/2] make spotless check pass --- .../dtstack/chunjun/connector/doris/options/DorisConf.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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 6d64f75b58..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,10 +180,10 @@ public JdbcConf setToJdbcConf() { jdbcConf.setJdbcUrl(url); jdbcConf.setPassword(password); jdbcConf.setUsername(username); - + jdbcConf.setBatchSize(this.getBatchSize()); jdbcConf.setFlushIntervalMills(this.getFlushIntervalMills()); - + return jdbcConf; } }