Skip to content

Commit

Permalink
[Bug][chunjun-connectors] jdbc's properties not work where jdbc's rea…
Browse files Browse the repository at this point in the history
…der has set properties
  • Loading branch information
AliceXiaoLu committed Feb 18, 2024
1 parent 58ec5f2 commit 1fb08c9
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -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);
Expand Down

0 comments on commit 1fb08c9

Please sign in to comment.