[tidb] Checkpoint is not updated long after a task has been running (#1686)

Co-authored-by: wangxiaojing <wangxiaojing@lixiang.com>
pull/1699/head
wangxiaojing 2 years ago committed by GitHub
parent e377c339b6
commit da5b322890
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

@ -243,7 +243,7 @@ public class TiKVRichParallelSourceFunction<T> extends RichParallelSourceFunctio
}
handleRow(row);
}
resolvedTs = cdcClient.getMinResolvedTs();
resolvedTs = cdcClient.getMaxResolvedTs();
if (commits.size() > 0) {
flushRows(resolvedTs);
}

Loading…
Cancel
Save