From f3225dfae7e6f4f63d2911ed0e55e0ad7171c196 Mon Sep 17 00:00:00 2001
From: gongzhongqiang <gongzhongqiang@gigacloudtech.com>
Date: Thu, 3 Nov 2022 14:40:56 +0800
Subject: [PATCH] [hotfix] Add method getMaxResolvedTs back to class CDCClient.

---
 .../src/main/java/org/tikv/cdc/CDCClient.java                 | 4 ++++
 1 file changed, 4 insertions(+)

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());
     }