when writing _river status, use consistency of one

Author: kimchy

modules/elasticsearch/src/main/java/org/elasticsearch/river/RiversService.java

@@ -23,6 +23,7 @@
 import org.elasticsearch.ExceptionsHelper;
 import org.elasticsearch.action.ActionListener;
 import org.elasticsearch.action.NoShardAvailableActionException;
+import org.elasticsearch.action.WriteConsistencyLevel;
 import org.elasticsearch.action.get.GetResponse;
 import org.elasticsearch.client.Client;
 import org.elasticsearch.cluster.ClusterService;
@@ -150,7 +151,9 @@ public synchronized void createRiver(RiverName riverName, Map<String, Object> se
             builder.endObject();
 
 
-            client.prepareIndex(riverIndexName, riverName.name(), "_status").setSource(builder).execute().actionGet();
+            client.prepareIndex(riverIndexName, riverName.name(), "_status")
+                    .setConsistencyLevel(WriteConsistencyLevel.ONE)
+                    .setSource(builder).execute().actionGet();
         } catch (Exception e) {
             logger.warn("failed to create river [{}][{}]", e, riverName.type(), riverName.name());
 
@@ -164,7 +167,9 @@ public synchronized void createRiver(RiverName riverName, Map<String, Object> se
                 builder.field("transport_address", clusterService.localNode().address().toString());
                 builder.endObject();
 
-                client.prepareIndex(riverIndexName, riverName.name(), "_status").setSource(builder).execute().actionGet();
+                client.prepareIndex(riverIndexName, riverName.name(), "_status")
+                        .setConsistencyLevel(WriteConsistencyLevel.ONE)
+                        .setSource(builder).execute().actionGet();
             } catch (Exception e1) {
                 logger.warn("failed to write failed status for river creation", e);
             }