Don't call ClusterService.state() in a ClusterStateUpdateTask

The current state is readily available as a parameter
This commit is contained in:
Yannick Welsch 2017-04-29 10:49:12 +02:00 committed by Martijn van Groningen
parent 44ea5d6b3e
commit e69317b24b
No known key found for this signature in database
GPG Key ID: AB236F4FCF2AF12A

@ -71,7 +71,7 @@ public class PersistentTasksClusterService extends AbstractComponent implements
if (builder.hasTask(taskId)) {
throw new ResourceAlreadyExistsException("task with id {" + taskId + "} already exist");
}
validate(action, clusterService.state(), params);
validate(action, currentState, params);
final Assignment assignment;
assignment = getAssignement(action, currentState, params);
return update(currentState, builder.addTask(taskId, action, params, assignment));