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

…der has set properties
DTStack · Feb 21, 2024 · 0f91dd5 · 0f91dd5
1 parent 38fed40
commit 0f91dd5
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
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);

diff --git a/chunjun-core/src/test/java/com/dtstack/chunjun/config/BaseFileConfigTest.java b/chunjun-core/src/test/java/com/dtstack/chunjun/config/BaseFileConfigTest.java
@@ -39,7 +39,7 @@ public void toStringShouldReturnAStringWithAllTheFields() {
         baseFileConf.setNextCheckRows(5000L);
 
         String expected =
-                "BaseFileConfig(fromLine=1, path=path, fileName=fileName, writeMode=writeMode, compress=compress, encoding=UTF-8, maxFileSize=1024, nextCheckRows=5000, suffix=null)";
+                "BaseFileConfig(fromLine=1, path=path, fileName=fileName, writeMode=writeMode, compress=compress, encoding=UTF-8, maxFileSize=1024, nextCheckRows=5000, suffix=null, jobIdentifier=)";
 
         assertEquals(expected, baseFileConf.toString());
     }