From 0b2ae3bb50fdf5a5149d429e8c36efe3c1210d9c Mon Sep 17 00:00:00 2001 From: Han Fei Date: Wed, 20 Nov 2019 13:31:13 +0800 Subject: [PATCH] SelectExecutor: get safe point with retry. --- dbms/src/Storages/MergeTree/MergeTreeDataSelectExecutor.cpp | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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),