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);