Skip to content

Commit 3cb7996

Browse files
committed
redmine 31608 增量任务,如果startLocation不为空,则将endLocation初始值设置为startLocation的值,防止数据库无增量数据时下次获取到的startLocation为空
1 parent 089868d commit 3cb7996

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

flinkx-rdb/flinkx-rdb-reader/src/main/java/com.dtstack.flinkx.rdb.inputformat/JdbcInputFormat.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -340,6 +340,11 @@ protected void initMetric(InputSplit inputSplit) {
340340
//endLocation设置为数据库中查询的最大值
341341
String endLocation = ((JdbcInputSplit) inputSplit).getEndLocation();
342342
endLocationAccumulator.add(new BigInteger(StringUtil.stringToTimestampStr(endLocation, type)));
343+
}else{
344+
//增量任务,且useMaxFunc设置为false,如果startLocation不为空,则将endLocation初始值设置为startLocation的值,防止数据库无增量数据时下次获取到的startLocation为空
345+
if (StringUtils.isNotEmpty(startLocation)) {
346+
endLocationAccumulator.add(new BigInteger(startLocation));
347+
}
343348
}
344349

345350
//将累加器信息添加至prometheus

0 commit comments

Comments
 (0)