[Internal] Migrate new initial state cluster update task to a ClusterStateNonMasterUpdateTask

This commit is contained in:
Boaz Leskes 2014-07-11 20:03:02 +02:00
parent c12d0901f6
commit e0543b3426

View File

@ -136,7 +136,7 @@ public class InternalClusterService extends AbstractLifecycleComponent<ClusterSe
discoveryService.addLifecycleListener(new LifecycleListener() {
@Override
public void afterStart() {
submitStateUpdateTask("update local node", Priority.IMMEDIATE, new ClusterStateUpdateTask() {
submitStateUpdateTask("update local node", Priority.IMMEDIATE, new ClusterStateNonMasterUpdateTask() {
@Override
public ClusterState execute(ClusterState currentState) throws Exception {
return ClusterState.builder(currentState)
@ -146,7 +146,7 @@ public class InternalClusterService extends AbstractLifecycleComponent<ClusterSe
@Override
public void onFailure(String source, Throwable t) {
logger.warn("failed ot update local node", t);
logger.warn("failed to update local node", t);
}
});
}