You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@phoenix.apache.org by mu...@apache.org on 2014/07/18 01:43:48 UTC
git commit: PHOENIX-1097 ChunkedResultIteratorFactory.newIterator is
not closing... (Samarth.Jain)
Repository: phoenix
Updated Branches:
refs/heads/master 7d40da239 -> fa04952de
PHOENIX-1097 ChunkedResultIteratorFactory.newIterator is not closing... (Samarth.Jain)
Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo
Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/fa04952d
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/fa04952d
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/fa04952d
Branch: refs/heads/master
Commit: fa04952de5ae7af5c27a7afc7bd31734a0c42e9c
Parents: 7d40da2
Author: mujtabachohan <mu...@me.com>
Authored: Thu Jul 17 16:43:35 2014 -0700
Committer: mujtabachohan <mu...@me.com>
Committed: Thu Jul 17 16:43:35 2014 -0700
----------------------------------------------------------------------
.../main/java/org/apache/phoenix/iterate/ChunkedResultIterator.java | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/phoenix/blob/fa04952d/phoenix-core/src/main/java/org/apache/phoenix/iterate/ChunkedResultIterator.java
----------------------------------------------------------------------
diff --git a/phoenix-core/src/main/java/org/apache/phoenix/iterate/ChunkedResultIterator.java b/phoenix-core/src/main/java/org/apache/phoenix/iterate/ChunkedResultIterator.java
index 5635114..92080eb 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/iterate/ChunkedResultIterator.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/iterate/ChunkedResultIterator.java
@@ -67,6 +67,7 @@ public class ChunkedResultIterator implements PeekingResultIterator {
if (HashJoinInfo.isHashJoin(context.getScan())) {
return delegateFactory.newIterator(context, scanner);
} else {
+ scanner.close(); //close the iterator since we don't need it anymore.
return new ChunkedResultIterator(delegateFactory, context, tableRef,
context.getConnection().getQueryServices().getProps().getLong(
QueryServices.SCAN_RESULT_CHUNK_SIZE,