diff --git a/dbms/src/Storages/MergeTree/MergeTreeDataSelectExecutor.cpp b/dbms/src/Storages/MergeTree/MergeTreeDataSelectExecutor.cpp
index b57ccf3a469..3b27014205c 100644
--- a/dbms/src/Storages/MergeTree/MergeTreeDataSelectExecutor.cpp
+++ b/dbms/src/Storages/MergeTree/MergeTreeDataSelectExecutor.cpp
@@ -835,7 +835,7 @@ BlockInputStreams MergeTreeDataSelectExecutor::read(const Names & column_names_t
     {
         TMTContext & tmt = context.getTMTContext();
 
-        auto safe_point = tmt.getPDClient()->getGCSafePoint();
+        auto safe_point = PDClientHelper::getGCSafePointWithRetry(tmt.getPDClient());
         if (mvcc_query_info.read_tso < safe_point)
             throw Exception("query id: " + context.getCurrentQueryId() + ", read tso: " + toString(mvcc_query_info.read_tso)
                     + " is smaller than tidb gc safe point: " + toString(safe_point),