[Bug][chunjun-connectors] jdbc's properties not work where jdbc's rea…

…der has set properties
DTStack · Sep 12, 2024 · 33c14a5 · 33c14a5
1 parent dfa3f7f
commit 33c14a5
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...-jdbc-base/src/main/java/com/dtstack/chunjun/connector/jdbc/source/JdbcSourceFactory.java b/...-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);