honeymoose
/
OpenSearch
mirror of https://github.com/honeymoose/OpenSearch.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Added more logging for percolator. 

Lowered log level in percolator tests.
This commit is contained in:
Martijn van Groningen 2013-12-10 15:45:04 +01:00
parent 794a927c43
commit 38cff53a0f
2 changed files with 27 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/main/java/org/elasticsearch/index/percolator/PercolatorQueriesRegistry.java
View File

@ -194,14 +194,18 @@ public class PercolatorQueriesRegistry extends AbstractIndexShardComponent {
@Override
public void created(String type) {
logger.trace("invoking created type listener for index [{}] and shard[{}] on node[{}]", shardId.index(), shardId.id(), nodeName());
if (PercolatorService.TYPE_NAME.equals(type)) {
logger.debug("enabling realtime percolating for index [{}] and shard[{}] on node[{}]", shardId.index(), shardId.id(), nodeName());
enableRealTimePercolator();
}
}
@Override
public void removed(String type) {
logger.trace("invoking removed type listener for index [{}] and shard[{}] on node[{}]", shardId.index(), shardId.id(), nodeName());
if (PercolatorService.TYPE_NAME.equals(type)) {
logger.debug("disabling realtime percolating for index [{}] and shard[{}] on node[{}]", shardId.index(), shardId.id(), nodeName());
disableRealTimePercolator();
clear();
}

23
src/test/java/org/elasticsearch/percolator/PercolatorTests.java
View File

@ -44,6 +44,7 @@ import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.index.query.functionscore.factor.FactorBuilder;
import org.elasticsearch.search.highlight.HighlightBuilder;
import org.elasticsearch.test.ElasticsearchIntegrationTest;
import org.elasticsearch.test.junit.annotations.TestLogging;
import org.junit.Test;
import java.util.*;
@ -63,6 +64,7 @@ import static org.hamcrest.Matchers.*;
public class PercolatorTests extends ElasticsearchIntegrationTest {
@Test
@TestLogging("index.percolator:TRACE,percolator:TRACE")
public void testSimple1() throws Exception {
client().admin().indices().prepareCreate("test").execute().actionGet();
ensureGreen();
@ -142,6 +144,7 @@ public class PercolatorTests extends ElasticsearchIntegrationTest {
}
@Test
@TestLogging("index.percolator:TRACE,percolator:TRACE")
public void testSimple2() throws Exception {
client().admin().indices().prepareCreate("index").setSettings(
ImmutableSettings.settingsBuilder()
@ -234,6 +237,7 @@ public class PercolatorTests extends ElasticsearchIntegrationTest {
}
@Test
@TestLogging("index.percolator:TRACE,percolator:TRACE")
public void testPercolateQueriesWithRouting() throws Exception {
client().admin().indices().prepareCreate("test")
.setSettings(settingsBuilder().put("index.number_of_shards", 2))
@ -276,6 +280,7 @@ public class PercolatorTests extends ElasticsearchIntegrationTest {
}
@Test
@TestLogging("index.percolator:TRACE,percolator:TRACE")
public void percolateOnRecreatedIndex() throws Exception {
prepareCreate("test").setSettings(settingsBuilder().put("index.number_of_shards", 1)).execute().actionGet();
ensureGreen();
@ -306,6 +311,7 @@ public class PercolatorTests extends ElasticsearchIntegrationTest {
}
@Test
@TestLogging("index.percolator:TRACE,percolator:TRACE")
// see #2814
public void percolateCustomAnalyzer() throws Exception {
Builder builder = ImmutableSettings.builder();
@ -348,6 +354,7 @@ public class PercolatorTests extends ElasticsearchIntegrationTest {
}
@Test
@TestLogging("index.percolator:TRACE,percolator:TRACE")
public void createIndexAndThenRegisterPercolator() throws Exception {
assertAcked(client().admin().indices().prepareCreate("test").setSettings(settingsBuilder().put("index.number_of_shards", 1)));
ensureGreen();
@ -397,6 +404,7 @@ public class PercolatorTests extends ElasticsearchIntegrationTest {
}
@Test
@TestLogging("index.percolator:TRACE,percolator:TRACE")
public void multiplePercolators() throws Exception {
client().admin().indices().prepareCreate("test").setSettings(settingsBuilder().put("index.number_of_shards", 1)).execute().actionGet();
ensureGreen();
@ -438,6 +446,7 @@ public class PercolatorTests extends ElasticsearchIntegrationTest {
}
@Test
@TestLogging("index.percolator:TRACE,percolator:TRACE")
public void dynamicAddingRemovingQueries() throws Exception {
client().admin().indices().prepareCreate("test").setSettings(settingsBuilder().put("index.number_of_shards", 1)).execute().actionGet();
ensureGreen();
@ -510,6 +519,7 @@ public class PercolatorTests extends ElasticsearchIntegrationTest {
}
@Test
@TestLogging("index.percolator:TRACE,percolator:TRACE")
public void percolateWithSizeField() throws Exception {
String mapping = XContentFactory.jsonBuilder().startObject().startObject("type1")
.startObject("_size").field("enabled", true).field("stored", "yes").endObject()
@ -543,6 +553,7 @@ public class PercolatorTests extends ElasticsearchIntegrationTest {
}
@Test
@TestLogging("index.percolator:TRACE,percolator:TRACE")
public void testPercolateStatistics() throws Exception {
client().admin().indices().prepareCreate("test").execute().actionGet();
ensureGreen();
@ -626,6 +637,7 @@ public class PercolatorTests extends ElasticsearchIntegrationTest {
}
@Test
@TestLogging("index.percolator:TRACE,percolator:TRACE")
public void testPercolatingExistingDocs() throws Exception {
client().admin().indices().prepareCreate("test").execute().actionGet();
ensureGreen();
@ -700,6 +712,7 @@ public class PercolatorTests extends ElasticsearchIntegrationTest {
}
@Test
@TestLogging("index.percolator:TRACE,percolator:TRACE")
public void testPercolatingExistingDocs_routing() throws Exception {
client().admin().indices().prepareCreate("test").execute().actionGet();
ensureGreen();
@ -766,6 +779,7 @@ public class PercolatorTests extends ElasticsearchIntegrationTest {
}
@Test
@TestLogging("index.percolator:TRACE,percolator:TRACE")
public void testPercolatingExistingDocs_versionCheck() throws Exception {
client().admin().indices().prepareCreate("test").execute().actionGet();
ensureGreen();
@ -827,6 +841,7 @@ public class PercolatorTests extends ElasticsearchIntegrationTest {
}
@Test
@TestLogging("index.percolator:TRACE,percolator:TRACE")
public void testPercolateMultipleIndicesAndAliases() throws Exception {
client().admin().indices().prepareCreate("test1")
.setSettings(settingsBuilder().put("index.number_of_shards", 2))
@ -911,6 +926,7 @@ public class PercolatorTests extends ElasticsearchIntegrationTest {
}
@Test
@TestLogging("index.percolator:TRACE,percolator:TRACE")
public void testCountPercolation() throws Exception {
client().admin().indices().prepareCreate("test").execute().actionGet();
ensureGreen();
@ -980,6 +996,7 @@ public class PercolatorTests extends ElasticsearchIntegrationTest {
}
@Test
@TestLogging("index.percolator:TRACE,percolator:TRACE")
public void testCountPercolatingExistingDocs() throws Exception {
client().admin().indices().prepareCreate("test").execute().actionGet();
ensureGreen();
@ -1042,6 +1059,7 @@ public class PercolatorTests extends ElasticsearchIntegrationTest {
}
@Test
@TestLogging("index.percolator:TRACE,percolator:TRACE")
public void testPercolateSizingWithQueryAndFilter() throws Exception {
client().admin().indices().prepareCreate("test").execute().actionGet();
ensureGreen();
@ -1131,6 +1149,7 @@ public class PercolatorTests extends ElasticsearchIntegrationTest {
}
@Test
@TestLogging("index.percolator:TRACE,percolator:TRACE")
public void testPercolateScoreAndSorting() throws Exception {
client().admin().indices().prepareCreate("my-index")
.setSettings(ImmutableSettings.settingsBuilder()
@ -1224,6 +1243,7 @@ public class PercolatorTests extends ElasticsearchIntegrationTest {
}
@Test
@TestLogging("index.percolator:TRACE,percolator:TRACE")
public void testPercolateSortingWithNoSize() throws Exception {
client().admin().indices().prepareCreate("my-index").execute().actionGet();
ensureGreen();
@ -1263,6 +1283,7 @@ public class PercolatorTests extends ElasticsearchIntegrationTest {
}
@Test
@TestLogging("index.percolator:TRACE,percolator:TRACE")
public void testPercolateOnEmptyIndex() throws Exception {
client().admin().indices().prepareCreate("my-index").execute().actionGet();
ensureGreen();
@ -1277,6 +1298,7 @@ public class PercolatorTests extends ElasticsearchIntegrationTest {
}
@Test
@TestLogging("index.percolator:TRACE,percolator:TRACE")
public void testPercolateNotEmptyIndexButNoRefresh() throws Exception {
client().admin().indices().prepareCreate("my-index")
.setSettings(ImmutableSettings.settingsBuilder().put("index.refresh_interval", -1))
@ -1466,6 +1488,7 @@ public class PercolatorTests extends ElasticsearchIntegrationTest {
}
@Test
@TestLogging("index.percolator:TRACE,percolator:TRACE")
public void testDeletePercolatorType() throws Exception {
DeleteIndexResponse deleteIndexResponse = client().admin().indices().prepareDelete().execute().actionGet();
assertThat("Delete Index failed - not acked", deleteIndexResponse.isAcknowledged(), equalTo(true));