add node and order to the source of update mapping

kimchy · kimchy · commit 36a76cc0ab20 · 2013-12-08T03:32:10.000+01:00
diff --git a/src/main/java/org/elasticsearch/cluster/metadata/MetaDataMappingService.java b/src/main/java/org/elasticsearch/cluster/metadata/MetaDataMappingService.java
@@ -356,7 +356,7 @@ public void updateMapping(final String index, final String indexUUID, final Stri
             insertOrder = ++refreshOrUpdateInsertOrder;
             refreshOrUpdateQueue.add(new UpdateTask(index, indexUUID, type, mappingSource, order, nodeId, listener));
         }
-        clusterService.submitStateUpdateTask("update-mapping [" + index + "][" + type + "]", Priority.HIGH, new ClusterStateUpdateTask() {
+        clusterService.submitStateUpdateTask("update-mapping [" + index + "][" + type + "] / node [" + nodeId + "], order [" + order + "]", Priority.HIGH, new ClusterStateUpdateTask() {
             @Override
             public void onFailure(String source, Throwable t) {
                 listener.onFailure(t);

Original file line number	Diff line number	Diff line change
`@@ -356,7 +356,7 @@ public void updateMapping(final String index, final String indexUUID, final Stri`
`356`	`356`	`insertOrder = ++refreshOrUpdateInsertOrder;`
`357`	`357`	`refreshOrUpdateQueue.add(new UpdateTask(index, indexUUID, type, mappingSource, order, nodeId, listener));`
`358`	`358`	`}`
`359`		`- clusterService.submitStateUpdateTask("update-mapping [" + index + "][" + type + "]", Priority.HIGH, new ClusterStateUpdateTask() {`
	`359`	`+ clusterService.submitStateUpdateTask("update-mapping [" + index + "][" + type + "] / node [" + nodeId + "], order [" + order + "]", Priority.HIGH, new ClusterStateUpdateTask() {`
`360`	`360`	`@Override`
`361`	`361`	`public void onFailure(String source, Throwable t) {`
`362`	`362`	`listener.onFailure(t);`