This is an automated email from the ASF dual-hosted git repository. stoty pushed a commit to branch 5.1 in repository https://gitbox.apache.org/repos/asf/phoenix.git
The following commit(s) were added to refs/heads/5.1 by this push: new 527c3666b4 PHOENIX-7000 Always schedule RenewLeaseTasks (#1642) 527c3666b4 is described below commit 527c3666b4da7d0f7c77ec693c9bdb5e371a489d 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 23c18d71c0..831c664813 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 @@ -3362,7 +3362,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, @@ -3377,6 +3376,9 @@ public class ConnectionQueryServicesImpl extends DelegateQueryServices implement initializationException = new SQLException(e); } } finally { + if (success) { + scheduleRenewLeaseTasks(); + } try { if (!success && hConnectionEstablished) { closeConnection();