You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@phoenix.apache.org by td...@apache.org on 2018/02/22 18:42:42 UTC
phoenix git commit: PHOENIX-4625 memory leak in PhoenixConnection if
scanner renew lease thread is not enabled
Repository: phoenix
Updated Branches:
refs/heads/4.x-HBase-0.98 ac8c9ee97 -> 4fc3f7545
PHOENIX-4625 memory leak in PhoenixConnection if scanner renew lease thread is not enabled
Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo
Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/4fc3f754
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/4fc3f754
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/4fc3f754
Branch: refs/heads/4.x-HBase-0.98
Commit: 4fc3f7545db831e83bc82783a0655df79821c107
Parents: ac8c9ee
Author: Vikas Vishwakarma <vv...@salesforce.com>
Authored: Thu Feb 22 11:13:34 2018 +0530
Committer: Thomas D'Silva <td...@apache.org>
Committed: Thu Feb 22 10:41:54 2018 -0800
----------------------------------------------------------------------
.../src/main/java/org/apache/phoenix/jdbc/PhoenixConnection.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/phoenix/blob/4fc3f754/phoenix-core/src/main/java/org/apache/phoenix/jdbc/PhoenixConnection.java
----------------------------------------------------------------------
diff --git a/phoenix-core/src/main/java/org/apache/phoenix/jdbc/PhoenixConnection.java b/phoenix-core/src/main/java/org/apache/phoenix/jdbc/PhoenixConnection.java
index 5b6ab58..7c9f478 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/jdbc/PhoenixConnection.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/jdbc/PhoenixConnection.java
@@ -1220,7 +1220,7 @@ public class PhoenixConnection implements Connection, MetaDataMutated, SQLClosea
}
public void addIteratorForLeaseRenewal(@Nonnull TableResultIterator itr) {
- if (services.supportsFeature(Feature.RENEW_LEASE)) {
+ if (services.isRenewingLeasesEnabled()) {
checkNotNull(itr);
scannerQueue.add(new WeakReference<TableResultIterator>(itr));
}