chunjun
chunjun copied to clipboard
同时设置增量字段和切分键,切分键会被增量字段覆盖
trafficstars
com.dtstack.chunjun.connector.jdbc.source.JdbcInputFormatBuilder#checkFormat
if (conf.isIncrement()) { if (StringUtils.isBlank(conf.getIncreColumn())) { sb.append("increColumn can't be empty when increment is true;\n"); } **conf.setSplitPk(conf.getIncreColumn());** if (conf.getParallelism() > 1) { conf.setSplitStrategy("mod"); } }
Can you submit a pr to fix this bug?