diff --git a/src/main/java/org/elasticsearch/action/admin/indices/flush/FlushRequest.java b/src/main/java/org/elasticsearch/action/admin/indices/flush/FlushRequest.java index d6c1530de0e..e34ac8cfab5 100644 --- a/src/main/java/org/elasticsearch/action/admin/indices/flush/FlushRequest.java +++ b/src/main/java/org/elasticsearch/action/admin/indices/flush/FlushRequest.java @@ -108,4 +108,10 @@ public class FlushRequest extends BroadcastOperationRequest { waitIfOngoing = in.readBoolean(); } + @Override + public String toString() { + return "FlushRequest{" + + "waitIfOngoing=" + waitIfOngoing + + ", force=" + force + "}"; + } } diff --git a/src/main/java/org/elasticsearch/index/engine/InternalEngine.java b/src/main/java/org/elasticsearch/index/engine/InternalEngine.java index 172f436ec69..9b2c6e66c06 100644 --- a/src/main/java/org/elasticsearch/index/engine/InternalEngine.java +++ b/src/main/java/org/elasticsearch/index/engine/InternalEngine.java @@ -147,6 +147,7 @@ public class InternalEngine extends Engine { } } } + logger.trace("created new InternalEngine"); } private SearcherManager createSearcherManager() throws EngineException { diff --git a/src/main/java/org/elasticsearch/index/engine/ShadowEngine.java b/src/main/java/org/elasticsearch/index/engine/ShadowEngine.java index 33140671829..ba23903ee4b 100644 --- a/src/main/java/org/elasticsearch/index/engine/ShadowEngine.java +++ b/src/main/java/org/elasticsearch/index/engine/ShadowEngine.java @@ -90,6 +90,7 @@ public class ShadowEngine extends Engine { } catch (IOException ex) { throw new EngineCreationFailureException(shardId, "failed to open index reader", ex); } + logger.trace("created new ShadowEngine"); } diff --git a/src/main/java/org/elasticsearch/index/shard/IndexShard.java b/src/main/java/org/elasticsearch/index/shard/IndexShard.java index e6d13ab7428..067978a24bc 100644 --- a/src/main/java/org/elasticsearch/index/shard/IndexShard.java +++ b/src/main/java/org/elasticsearch/index/shard/IndexShard.java @@ -561,7 +561,7 @@ public class IndexShard extends AbstractIndexShardComponent { public void refresh(String source) throws ElasticsearchException { verifyNotClosed(); if (logger.isTraceEnabled()) { - logger.trace("refresh with soruce: {}", source); + logger.trace("refresh with source: {}", source); } long time = System.nanoTime(); engine().refresh(source); diff --git a/src/main/java/org/elasticsearch/indices/IndicesService.java b/src/main/java/org/elasticsearch/indices/IndicesService.java index 98eb81fbdce..153ed395d15 100644 --- a/src/main/java/org/elasticsearch/indices/IndicesService.java +++ b/src/main/java/org/elasticsearch/indices/IndicesService.java @@ -291,7 +291,11 @@ public class IndicesService extends AbstractLifecycleComponent i indicesLifecycle.beforeIndexCreated(index, settings); - logger.debug("creating Index [{}], shards [{}]/[{}]", sIndexName, settings.get(SETTING_NUMBER_OF_SHARDS), settings.get(SETTING_NUMBER_OF_REPLICAS)); + logger.debug("creating Index [{}], shards [{}]/[{}{}]", + sIndexName, + settings.get(SETTING_NUMBER_OF_SHARDS), + settings.get(SETTING_NUMBER_OF_REPLICAS), + IndexMetaData.isIndexUsingShadowReplicas(settings) ? "s" : ""); Settings indexSettings = settingsBuilder() .put(this.settings) diff --git a/src/test/java/org/elasticsearch/index/IndexWithShadowReplicasTests.java b/src/test/java/org/elasticsearch/index/IndexWithShadowReplicasTests.java index e36dbb8be2a..438f461b31b 100644 --- a/src/test/java/org/elasticsearch/index/IndexWithShadowReplicasTests.java +++ b/src/test/java/org/elasticsearch/index/IndexWithShadowReplicasTests.java @@ -47,10 +47,7 @@ import java.util.concurrent.ExecutionException; import static com.google.common.collect.Lists.newArrayList; import static org.elasticsearch.index.query.QueryBuilders.matchAllQuery; import static org.elasticsearch.test.hamcrest.ElasticsearchAssertions.*; -import static org.elasticsearch.test.hamcrest.ElasticsearchAssertions.assertAcked; -import static org.hamcrest.Matchers.equalTo; -import static org.hamcrest.Matchers.greaterThan; -import static org.hamcrest.Matchers.greaterThanOrEqualTo; +import static org.hamcrest.Matchers.*; /** * Tests for indices that use shadow replicas and a shared filesystem @@ -120,7 +117,7 @@ public class IndexWithShadowReplicasTests extends ElasticsearchIntegrationTest { } - @Test + @Test public void testIndexWithFewDocuments() throws Exception { Settings nodeSettings = ImmutableSettings.builder() .put("node.add_id_to_custom_path", false)