DTStack / DTStack/chunjun

同时设置增量字段和切分键,切分键会被增量字段覆盖

Open
#851 1 comment 0 reactions 0 assignees View on GitHub
bug
Dominant language
Java
Stars
4.1k
Forks
1.7k
PR merge metrics
No merged PRs in 30d

Description

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");
}
}`

Contributor guide

Open the contributing guide

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.