Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion docs/changelog/83760.yaml
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
pr: 83760
summary: Batch open-indices
summary: Batch open-indices cluster state updates
area: Indices APIs
type: enhancement
issues: []
Original file line number Diff line number Diff line change
Expand Up @@ -1078,7 +1078,17 @@ public ClusterTasksResult<OpenIndicesTask> execute(ClusterState currentState, Li
state = allocationService.reroute(state, "indices opened");

for (OpenIndicesTask task : tasks) {
builder.success(task, new LegacyClusterTaskResultActionListener(task, currentState));
builder.success(task, new ActionListener<>() {
@Override
public void onResponse(ClusterState clusterState) {
// listener is notified at the end of acking
}

@Override
public void onFailure(Exception e) {
task.onFailure(e);
}
});
}
} catch (Exception e) {
for (OpenIndicesTask task : tasks) {
Expand Down Expand Up @@ -1191,5 +1201,10 @@ public void onAckTimeout() {
public TimeValue ackTimeout() {
return request.ackTimeout();
}

@Override
public void clusterStateProcessed(ClusterState oldState, ClusterState newState) {
assert false : "not called";
}
}
}