Fixing a memory leak that occurs over time with more controller connections and more tables. It is compounded when the number of remote threads in the controllers is very high.
Project: http://git-wip-us.apache.org/repos/asf/incubator-blur/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-blur/commit/13cef3ba Tree: http://git-wip-us.apache.org/repos/asf/incubator-blur/tree/13cef3ba Diff: http://git-wip-us.apache.org/repos/asf/incubator-blur/diff/13cef3ba Branch: refs/heads/blur-384-random-port-cleanup Commit: 13cef3ba405263ae01b4ce3881ba8ebc2d06b4a4 Parents: 89e10a0 Author: Aaron McCurry <[email protected]> Authored: Fri Oct 3 08:07:11 2014 -0400 Committer: Aaron McCurry <[email protected]> Committed: Fri Oct 3 08:07:11 2014 -0400 ---------------------------------------------------------------------- .../java/org/apache/blur/lucene/search/IterablePaging.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/13cef3ba/blur-query/src/main/java/org/apache/blur/lucene/search/IterablePaging.java ---------------------------------------------------------------------- diff --git a/blur-query/src/main/java/org/apache/blur/lucene/search/IterablePaging.java b/blur-query/src/main/java/org/apache/blur/lucene/search/IterablePaging.java index 0aa7b4a..3bb2d74 100644 --- a/blur-query/src/main/java/org/apache/blur/lucene/search/IterablePaging.java +++ b/blur-query/src/main/java/org/apache/blur/lucene/search/IterablePaging.java @@ -82,7 +82,11 @@ public class IterablePaging implements BlurIterable<ScoreDoc, BlurException> { _totalHitsRef = totalHitsRef == null ? new TotalHitsRef() : totalHitsRef; _progressRef = progressRef == null ? new ProgressRef() : progressRef; _runSlow = runSlow; - _key = new DeepPageKey(_query, _sort, _searcher.getIndexReader().getCombinedCoreAndDeletesKey()); + if (DISABLED) { + _key = null; + } else { + _key = new DeepPageKey(_query, _sort, _searcher.getIndexReader().getCombinedCoreAndDeletesKey()); + } } public static class TotalHitsRef {
