diff options
author | Martijn van Groningen <martijn.v.groningen@gmail.com> | 2017-04-19 20:37:20 +0200 |
---|---|---|
committer | Martijn van Groningen <martijn.v.groningen@gmail.com> | 2017-04-26 11:08:15 +0200 |
commit | c17de49a6dc1d54fcfee3754211ae67a06bdcec7 (patch) | |
tree | 5d8b1a76333dcfbe7dc9cb16fc95067fd98d4fc3 /core/src/test/java/org/elasticsearch/search/aggregations/bucket | |
parent | 51b33f1fd549b474e901e70a460440d73a1751ce (diff) |
[percolator] Fix memory leak when percolator uses bitset or field data cache.
The percolator doesn't close the IndexReader of the memory index any more.
Prior to 2.x the percolator had its own SearchContext (PercolatorContext) that did this,
but that was removed when the percolator was refactored as part of the 5.0 release.
I think an alternative way to fix this is to let percolator not use the bitset and fielddata caches,
that way we prevent the memory leak.
Closes #24108
Diffstat (limited to 'core/src/test/java/org/elasticsearch/search/aggregations/bucket')
2 files changed, 7 insertions, 7 deletions
diff --git a/core/src/test/java/org/elasticsearch/search/aggregations/bucket/nested/NestedAggregatorTests.java b/core/src/test/java/org/elasticsearch/search/aggregations/bucket/nested/NestedAggregatorTests.java index cdd2251fb6..304b7f03c5 100644 --- a/core/src/test/java/org/elasticsearch/search/aggregations/bucket/nested/NestedAggregatorTests.java +++ b/core/src/test/java/org/elasticsearch/search/aggregations/bucket/nested/NestedAggregatorTests.java @@ -65,7 +65,7 @@ public class NestedAggregatorTests extends AggregatorTestCase { try (RandomIndexWriter iw = new RandomIndexWriter(random(), directory)) { // intentionally not writing any docs } - try (IndexReader indexReader = DirectoryReader.open(directory)) { + try (IndexReader indexReader = wrap(DirectoryReader.open(directory))) { NestedAggregationBuilder nestedBuilder = new NestedAggregationBuilder(NESTED_AGG, NESTED_OBJECT); MaxAggregationBuilder maxAgg = new MaxAggregationBuilder(MAX_AGG_NAME) @@ -112,7 +112,7 @@ public class NestedAggregatorTests extends AggregatorTestCase { } iw.commit(); } - try (IndexReader indexReader = DirectoryReader.open(directory)) { + try (IndexReader indexReader = wrap(DirectoryReader.open(directory))) { NestedAggregationBuilder nestedBuilder = new NestedAggregationBuilder(NESTED_AGG, NESTED_OBJECT); MaxAggregationBuilder maxAgg = new MaxAggregationBuilder(MAX_AGG_NAME) @@ -160,7 +160,7 @@ public class NestedAggregatorTests extends AggregatorTestCase { } iw.commit(); } - try (IndexReader indexReader = DirectoryReader.open(directory)) { + try (IndexReader indexReader = wrap(DirectoryReader.open(directory))) { NestedAggregationBuilder nestedBuilder = new NestedAggregationBuilder(NESTED_AGG, NESTED_OBJECT + "." + NESTED_OBJECT2); MaxAggregationBuilder maxAgg = new MaxAggregationBuilder(MAX_AGG_NAME) @@ -213,7 +213,7 @@ public class NestedAggregatorTests extends AggregatorTestCase { iw.addDocuments(documents); iw.commit(); } - try (IndexReader indexReader = DirectoryReader.open(directory)) { + try (IndexReader indexReader = wrap(DirectoryReader.open(directory))) { NestedAggregationBuilder nestedBuilder = new NestedAggregationBuilder(NESTED_AGG, NESTED_OBJECT); SumAggregationBuilder sumAgg = new SumAggregationBuilder(SUM_AGG_NAME) @@ -292,7 +292,7 @@ public class NestedAggregatorTests extends AggregatorTestCase { iw.commit(); iw.close(); } - try (IndexReader indexReader = DirectoryReader.open(directory)) { + try (IndexReader indexReader = wrap(DirectoryReader.open(directory))) { NestedAggregationBuilder nestedBuilder = new NestedAggregationBuilder(NESTED_AGG, "nested_field"); diff --git a/core/src/test/java/org/elasticsearch/search/aggregations/bucket/nested/ReverseNestedAggregatorTests.java b/core/src/test/java/org/elasticsearch/search/aggregations/bucket/nested/ReverseNestedAggregatorTests.java index ce6ec7794b..74fb7ca9ca 100644 --- a/core/src/test/java/org/elasticsearch/search/aggregations/bucket/nested/ReverseNestedAggregatorTests.java +++ b/core/src/test/java/org/elasticsearch/search/aggregations/bucket/nested/ReverseNestedAggregatorTests.java @@ -54,7 +54,7 @@ public class ReverseNestedAggregatorTests extends AggregatorTestCase { try (RandomIndexWriter iw = new RandomIndexWriter(random(), directory)) { // intentionally not writing any docs } - try (IndexReader indexReader = DirectoryReader.open(directory)) { + try (IndexReader indexReader = wrap(DirectoryReader.open(directory))) { NestedAggregationBuilder nestedBuilder = new NestedAggregationBuilder(NESTED_AGG, NESTED_OBJECT); ReverseNestedAggregationBuilder reverseNestedBuilder @@ -117,7 +117,7 @@ public class ReverseNestedAggregatorTests extends AggregatorTestCase { } iw.commit(); } - try (IndexReader indexReader = DirectoryReader.open(directory)) { + try (IndexReader indexReader = wrap(DirectoryReader.open(directory))) { NestedAggregationBuilder nestedBuilder = new NestedAggregationBuilder(NESTED_AGG, NESTED_OBJECT); ReverseNestedAggregationBuilder reverseNestedBuilder |