Updated Branches: refs/heads/flume-1.4 90b5ed744 -> 011ff9571
FLUME-1862. ElasticSearchSink test is flakey. (Cameron Gandevia via Hari Shreedharan) Project: http://git-wip-us.apache.org/repos/asf/flume/repo Commit: http://git-wip-us.apache.org/repos/asf/flume/commit/011ff957 Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/011ff957 Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/011ff957 Branch: refs/heads/flume-1.4 Commit: 011ff9571e15350d48bc61b68f89d6e0eec32a77 Parents: 90b5ed7 Author: Hari Shreedharan <[email protected]> Authored: Mon Jan 21 23:27:36 2013 -0800 Committer: Hari Shreedharan <[email protected]> Committed: Mon Jan 21 23:28:31 2013 -0800 ---------------------------------------------------------------------- .../AbstractElasticSearchSinkTest.java | 12 +++++++++++- 1 files changed, 11 insertions(+), 1 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flume/blob/011ff957/flume-ng-sinks/flume-ng-elasticsearch-sink/src/test/java/org/apache/flume/sink/elasticsearch/AbstractElasticSearchSinkTest.java ---------------------------------------------------------------------- diff --git a/flume-ng-sinks/flume-ng-elasticsearch-sink/src/test/java/org/apache/flume/sink/elasticsearch/AbstractElasticSearchSinkTest.java b/flume-ng-sinks/flume-ng-elasticsearch-sink/src/test/java/org/apache/flume/sink/elasticsearch/AbstractElasticSearchSinkTest.java index 6d472cf..2edacdc 100644 --- a/flume-ng-sinks/flume-ng-elasticsearch-sink/src/test/java/org/apache/flume/sink/elasticsearch/AbstractElasticSearchSinkTest.java +++ b/flume-ng-sinks/flume-ng-elasticsearch-sink/src/test/java/org/apache/flume/sink/elasticsearch/AbstractElasticSearchSinkTest.java @@ -38,6 +38,8 @@ import org.apache.flume.conf.Configurables; import org.elasticsearch.action.search.SearchResponse; import org.elasticsearch.client.Client; import org.elasticsearch.common.collect.Maps; +import org.elasticsearch.common.settings.ImmutableSettings; +import org.elasticsearch.common.settings.Settings; import org.elasticsearch.gateway.Gateway; import org.elasticsearch.index.query.QueryBuilder; import org.elasticsearch.index.query.QueryBuilders; @@ -71,7 +73,15 @@ public abstract class AbstractElasticSearchSinkTest { } void createNodes() throws Exception { - node = NodeBuilder.nodeBuilder().local(true).node(); + Settings settings = ImmutableSettings + .settingsBuilder() + .put("number_of_shards", 1) + .put("number_of_replicas", 0) + .put("routing.hash.type", "simple") + .put("gateway.type", "none") + .build(); + + node = NodeBuilder.nodeBuilder().settings(settings).local(true).node(); client = node.client(); client.admin().cluster().prepareHealth().setWaitForGreenStatus().execute()
