phoenix-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tdsi...@apache.org
Subject phoenix git commit: PHOENIX-4460 High GC / RS shutdown when we use select query with IN clause using 4.10 phoenix client on 4.13 phoenix server
Date Tue, 19 Dec 2017 04:30:09 GMT
Repository: phoenix
Updated Branches:
  refs/heads/4.13-HBase-0.98 455d0a6e4 -> 1fdd10c8d


PHOENIX-4460 High GC / RS shutdown when we use select query with IN clause using 4.10 phoenix
client on 4.13 phoenix server


Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo
Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/1fdd10c8
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/1fdd10c8
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/1fdd10c8

Branch: refs/heads/4.13-HBase-0.98
Commit: 1fdd10c8d9533af3091c49492ba4a7ee9def78af
Parents: 455d0a6
Author: Thomas D'Silva <tdsilva@apache.org>
Authored: Thu Dec 14 15:41:42 2017 -0800
Committer: Thomas D'Silva <tdsilva@apache.org>
Committed: Mon Dec 18 12:04:40 2017 -0800

----------------------------------------------------------------------
 .../apache/phoenix/coprocessor/BaseScannerRegionObserver.java   | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/phoenix/blob/1fdd10c8/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/BaseScannerRegionObserver.java
----------------------------------------------------------------------
diff --git a/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/BaseScannerRegionObserver.java
b/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/BaseScannerRegionObserver.java
index df5ebc7..4122a8f 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/BaseScannerRegionObserver.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/BaseScannerRegionObserver.java
@@ -357,7 +357,10 @@ abstract public class BaseScannerRegionObserver extends BaseRegionObserver
{
       if (scan.isRaw() || ScanInfoUtil.isKeepDeletedCells(store.getScanInfo()) || scan.getTimeRange().getMax()
== HConstants.LATEST_TIMESTAMP || TransactionUtil.isTransactionalTimestamp(scan.getTimeRange().getMax()))
{
         return s;
       }
-
+      
+      if (s!=null) {
+          s.close();
+      }
       ScanInfo scanInfo = ScanInfoUtil.cloneScanInfoWithKeepDeletedCells(store.getScanInfo());
       return new StoreScanner(store, scanInfo, scan, targetCols,
           c.getEnvironment().getRegion().getReadpoint(scan.getIsolationLevel()));


Mime
View raw message