diff --git a/flink-connector-tidb-cdc/src/main/java/org/tikv/cdc/CDCClient.java b/flink-connector-tidb-cdc/src/main/java/org/tikv/cdc/CDCClient.java
index fa6021fcbe..513527971b 100644
--- a/flink-connector-tidb-cdc/src/main/java/org/tikv/cdc/CDCClient.java
+++ b/flink-connector-tidb-cdc/src/main/java/org/tikv/cdc/CDCClient.java
@@ -120,6 +120,10 @@ public synchronized long getMinResolvedTs() {
         return resolvedTsSet.firstEntry().getElement();
     }
 
+    public synchronized long getMaxResolvedTs() {
+        return resolvedTsSet.lastEntry().getElement();
+    }
+
     public synchronized void close() {
         removeRegions(regionClients.keySet());
     }