You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@phoenix.apache.org by st...@apache.org on 2023/07/31 08:09:20 UTC
[phoenix] branch 5.1 updated: PHOENIX-7000 Always schedule RenewLeaseTasks (#1642)
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 <ri...@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();