Skip to content

Commit

Permalink
tweak
Browse files Browse the repository at this point in the history
  • Loading branch information
ywangd committed Oct 10, 2023
1 parent a48d98a commit 3e326e3
Showing 1 changed file with 1 addition and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -484,8 +484,7 @@ public void onFailure(Exception e) {

private MasterServiceTaskQueue<SetClusterStateTask> createSetClusterStateTaskQueue(ClusterService clusterService) {
return clusterService.createTaskQueue("set-cluster-state", Priority.NORMAL, batchExecutionContext -> {
final ClusterState initialState = batchExecutionContext.initialState();
ClusterState targetState = initialState;
ClusterState targetState = batchExecutionContext.initialState();
for (var taskContext : batchExecutionContext.taskContexts()) {
targetState = taskContext.getTask().clusterState();
taskContext.success(() -> {});
Expand Down

0 comments on commit 3e326e3

Please sign in to comment.