diff --git a/server/src/main/java/org/elasticsearch/action/admin/indices/readonly/AddIndexBlockClusterStateUpdateRequest.java b/server/src/main/java/org/elasticsearch/action/admin/indices/readonly/AddIndexBlockClusterStateUpdateRequest.java index b0827c2978587..f48c550d73efd 100644 --- a/server/src/main/java/org/elasticsearch/action/admin/indices/readonly/AddIndexBlockClusterStateUpdateRequest.java +++ b/server/src/main/java/org/elasticsearch/action/admin/indices/readonly/AddIndexBlockClusterStateUpdateRequest.java @@ -21,7 +21,8 @@ public record AddIndexBlockClusterStateUpdateRequest( TimeValue masterNodeTimeout, TimeValue ackTimeout, APIBlock block, - boolean markVerified, long taskId, + boolean markVerified, + long taskId, Index[] indices ) { public AddIndexBlockClusterStateUpdateRequest { diff --git a/server/src/main/java/org/elasticsearch/action/admin/indices/readonly/AddIndexBlockRequest.java b/server/src/main/java/org/elasticsearch/action/admin/indices/readonly/AddIndexBlockRequest.java index 41ba30e3dfeba..20201bf7fe058 100644 --- a/server/src/main/java/org/elasticsearch/action/admin/indices/readonly/AddIndexBlockRequest.java +++ b/server/src/main/java/org/elasticsearch/action/admin/indices/readonly/AddIndexBlockRequest.java @@ -114,10 +114,11 @@ public boolean markVerified() { return markVerified; } - public AddIndexBlockRequest markVerified(boolean markVerified) { + public AddIndexBlockRequest markVerified(boolean markVerified) { this.markVerified = markVerified; return this; } + /** * Returns the block to be added */ diff --git a/server/src/main/java/org/elasticsearch/cluster/metadata/MetadataIndexStateService.java b/server/src/main/java/org/elasticsearch/cluster/metadata/MetadataIndexStateService.java index 7c4a61bf70f45..6e83656b19bd7 100644 --- a/server/src/main/java/org/elasticsearch/cluster/metadata/MetadataIndexStateService.java +++ b/server/src/main/java/org/elasticsearch/cluster/metadata/MetadataIndexStateService.java @@ -513,9 +513,10 @@ public void taskSucceeded(AddBlocksTask task, Map blockedIn task.request, blockedIndices, verifyResults, - task.request().markVerified() && clusterService.state() - .getMinTransportVersion() - .onOrAfter(TransportVersions.ADD_INDEX_BLOCK_TWO_PHASE), + task.request().markVerified() + && clusterService.state() + .getMinTransportVersion() + .onOrAfter(TransportVersions.ADD_INDEX_BLOCK_TWO_PHASE), delegate2 ), null