From 33c14a5c53f26b6b094b3cd51b95124e3ae6178c Mon Sep 17 00:00:00 2001 From: AliceXiaoLu Date: Wed, 21 Feb 2024 09:32:03 +0000 Subject: [PATCH] [Bug][chunjun-connectors] jdbc's properties not work where jdbc's reader has set properties --- .../chunjun/connector/jdbc/source/JdbcSourceFactory.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/chunjun-connectors/chunjun-connector-jdbc-base/src/main/java/com/dtstack/chunjun/connector/jdbc/source/JdbcSourceFactory.java b/chunjun-connectors/chunjun-connector-jdbc-base/src/main/java/com/dtstack/chunjun/connector/jdbc/source/JdbcSourceFactory.java index 88afcf9f9a..cc41ef113a 100644 --- a/chunjun-connectors/chunjun-connector-jdbc-base/src/main/java/com/dtstack/chunjun/connector/jdbc/source/JdbcSourceFactory.java +++ b/chunjun-connectors/chunjun-connector-jdbc-base/src/main/java/com/dtstack/chunjun/connector/jdbc/source/JdbcSourceFactory.java @@ -89,7 +89,7 @@ public JdbcSourceFactory( if (StringUtils.isBlank(jdbcConfig.getIncreColumn())) jdbcConfig.setPolling(false); jdbcConfig.setColumn(syncConfig.getReader().getFieldList()); - Properties properties = syncConfig.getWriter().getProperties("properties", null); + Properties properties = syncConfig.getReader().getProperties("properties", null); jdbcConfig.setProperties(properties); setDefaultSplitStrategy(jdbcConfig);