[phoenix] branch master updated: PHOENIX-7000 Always schedule RenewLeaseTasks (#1642)

[richardantal]

This is an automated email from the ASF dual-hosted git repository.

richardantal pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/phoenix.git


The following commit(s) were added to refs/heads/master by this push:
     new 986a16d3f8 PHOENIX-7000 Always schedule RenewLeaseTasks (#1642)
986a16d3f8 is described below

commit 986a16d3f803a92781cdfbb3bc64eb52ba90e38f
Author: richardantal <richardan...@apache.org>
AuthorDate: Mon Jul 31 10:00:47 2023 +0200

    PHOENIX-7000 Always schedule RenewLeaseTasks (#1642)
---
 .../java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java    | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java
 
b/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java
index f89a69646d..3ae740c6d8 100644
--- 
a/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java
+++ 
b/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java
@@ -3626,7 +3626,6 @@ public class ConnectionQueryServicesImpl extends 
DelegateQueryServices implement
                                             + "before any other command");
                                 }
                             }
-                            scheduleRenewLeaseTasks();
                             success = true;
                         } catch (RetriableUpgradeException e) {
                             // Set success to true and don't set the exception 
as an initializationException,
@@ -3641,6 +3640,9 @@ public class ConnectionQueryServicesImpl extends 
DelegateQueryServices implement
                                 initializationException = new SQLException(e);
                             }
                         } finally {
+                            if (success) {
+                                scheduleRenewLeaseTasks();
+                            }
                             try {
                                 if (!success && hConnectionEstablished) {
                                     closeConnection();