phoenix-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mujt...@apache.org
Subject git commit: PHOENIX-1097 ChunkedResultIteratorFactory.newIterator is not closing... (Samarth.Jain)
Date Thu, 17 Jul 2014 23:44:25 GMT
Repository: phoenix
Updated Branches:
  refs/heads/4.0 aa30b14af -> af1bd4e9c


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/af1bd4e9
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/af1bd4e9
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/af1bd4e9

Branch: refs/heads/4.0
Commit: af1bd4e9cb2a664b5e470943cf507a8502a007a8
Parents: aa30b14
Author: mujtabachohan <mujtabachohan@me.com>
Authored: Thu Jul 17 16:44:16 2014 -0700
Committer: mujtabachohan <mujtabachohan@me.com>
Committed: Thu Jul 17 16:44:16 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/af1bd4e9/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,


Mime
View raw message