New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Convert upgrade action to broadcast by node #13205
Conversation
@@ -134,7 +134,7 @@ private final Response newResponse(Request request, AtomicReferenceArray respons | |||
} | |||
totalShards += unavailableShardExceptions.size(); | |||
int failedShards = exceptions.size(); | |||
return newResponse(request, totalShards, successfulShards, failedShards, broadcastByNodeResponses, exceptions); | |||
return newResponse(request, totalShards, successfulShards, failedShards, broadcastByNodeResponses, exceptions, clusterService.state()); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
can we tunnel through the cluster state used in the action? that way we don't need to worry about consistency between the two (concurrent index deletion etc.)
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I've addressed this.
Thx @jasontedor . Left one minor comment. |
Several shard-level operations that previously broadcasted a request per shard were converted to broadcast a request per node. This commit converts upgrade action to this new model as well. Closes #13204
LGTM |
Convert upgrade action to broadcast by node
Thanks for reviewing @bleskes. I've merged this to master and integrated it into to 2.0. |
Several shard-level operations that previously broadcasted a request
per shard were converted to broadcast a request per node. This commit
converts upgrade action to this new model as well.
Closes #13204