You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flume.apache.org by hs...@apache.org on 2013/01/22 08:28:46 UTC
git commit: FLUME-1862. ElasticSearchSink test is flakey.
Updated Branches:
refs/heads/trunk 6d9ef1fd6 -> 4515117d5
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/4515117d
Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/4515117d
Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/4515117d
Branch: refs/heads/trunk
Commit: 4515117d56cff69accdf54ecbca0825ca6d71ab3
Parents: 6d9ef1f
Author: Hari Shreedharan <ha...@gmail.com>
Authored: Mon Jan 21 23:27:36 2013 -0800
Committer: Hari Shreedharan <ha...@gmail.com>
Committed: Mon Jan 21 23:27:36 2013 -0800
----------------------------------------------------------------------
.../AbstractElasticSearchSinkTest.java | 12 +++++++++++-
1 files changed, 11 insertions(+), 1 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flume/blob/4515117d/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()