honeymoose/OpenSearch
1
0
Fork 0
mirror of https://github.com/honeymoose/OpenSearch.git synced 2025-02-19 19:35:02 +00:00
Code Issues Packages Projects Releases Wiki Activity

when writing _river status, use consistency of one

Browse Source
This commit is contained in:
Shay Banon 2011-10-05 19:12:21 +02:00
parent 8f55e8835f
commit d69baa3e04
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
modules/elasticsearch/src/main/java/org/elasticsearch/river/RiversService.java
View File

@ -23,6 +23,7 @@ import org.elasticsearch.ElasticSearchException;
import org.elasticsearch.ExceptionsHelper; import org.elasticsearch.ExceptionsHelper;
import org.elasticsearch.action.ActionListener; import org.elasticsearch.action.ActionListener;
import org.elasticsearch.action.NoShardAvailableActionException; import org.elasticsearch.action.NoShardAvailableActionException;
import org.elasticsearch.action.WriteConsistencyLevel;
import org.elasticsearch.action.get.GetResponse; import org.elasticsearch.action.get.GetResponse;
import org.elasticsearch.client.Client; import org.elasticsearch.client.Client;
import org.elasticsearch.cluster.ClusterService; import org.elasticsearch.cluster.ClusterService;
@ -150,7 +151,9 @@ public class RiversService extends AbstractLifecycleComponent<RiversService> {
builder.endObject(); 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) { } catch (Exception e) {
logger.warn("failed to create river [{}][{}]", e, riverName.type(), riverName.name()); logger.warn("failed to create river [{}][{}]", e, riverName.type(), riverName.name());
@ -164,7 +167,9 @@ public class RiversService extends AbstractLifecycleComponent<RiversService> {
builder.field("transport_address", clusterService.localNode().address().toString()); builder.field("transport_address", clusterService.localNode().address().toString());
builder.endObject(); 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) { } catch (Exception e1) {
logger.warn("failed to write failed status for river creation", e); logger.warn("failed to write failed status for river creation", e);
} }