-
Notifications
You must be signed in to change notification settings - Fork 1.9k
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
Add changes for graceful node decommission #4586
Add changes for graceful node decommission #4586
Conversation
Signed-off-by: pranikum <109206473+pranikum@users.noreply.github.com>
Gradle Check (Jenkins) Run Completed with:
|
Signed-off-by: pranikum <109206473+pranikum@users.noreply.github.com>
Gradle Check (Jenkins) Run Completed with:
|
Signed-off-by: pranikum <109206473+pranikum@users.noreply.github.com>
Gradle Check (Jenkins) Run Completed with:
|
Gradle Check (Jenkins) Run Completed with:
|
Signed-off-by: pranikum <109206473+pranikum@users.noreply.github.com>
Gradle Check (Jenkins) Run Completed with:
|
Signed-off-by: pranikum <109206473+pranikum@users.noreply.github.com>
Signed-off-by: pranikum <109206473+pranikum@users.noreply.github.com>
Gradle Check (Jenkins) Run Completed with:
|
Gradle Check (Jenkins) Run Completed with:
|
Signed-off-by: pranikum <109206473+pranikum@users.noreply.github.com>
Gradle Check (Jenkins) Run Completed with:
|
server/src/main/java/org/opensearch/cluster/decommission/DecommissionController.java
Outdated
Show resolved
Hide resolved
server/src/main/java/org/opensearch/cluster/decommission/DecommissionController.java
Outdated
Show resolved
Hide resolved
server/src/main/java/org/opensearch/cluster/decommission/DecommissionController.java
Outdated
Show resolved
Hide resolved
server/src/main/java/org/opensearch/cluster/decommission/DecommissionController.java
Outdated
Show resolved
Hide resolved
Signed-off-by: pranikum <109206473+pranikum@users.noreply.github.com>
Gradle Check (Jenkins) Run Completed with:
|
Signed-off-by: pranikum <109206473+pranikum@users.noreply.github.com>
Signed-off-by: pranikum <109206473+pranikum@users.noreply.github.com>
Gradle Check (Jenkins) Run Completed with:
|
Gradle Check (Jenkins) Run Completed with:
|
Gradle Check (Jenkins) Run Completed with:
|
Signed-off-by: pranikum <109206473+pranikum@users.noreply.github.com>
Gradle Check (Jenkins) Run Completed with:
|
Signed-off-by: pranikum <109206473+pranikum@users.noreply.github.com>
Gradle Check (Jenkins) Run Completed with:
|
Signed-off-by: pranikum <109206473+pranikum@users.noreply.github.com>
Gradle Check (Jenkins) Run Completed with:
|
Signed-off-by: pranikum <109206473+pranikum@users.noreply.github.com>
Signed-off-by: pranikum <109206473+pranikum@users.noreply.github.com>
Signed-off-by: pranikum <109206473+pranikum@users.noreply.github.com>
Gradle Check (Jenkins) Run Completed with:
|
Gradle Check (Jenkins) Run Completed with:
|
Gradle Check (Jenkins) Run Completed with:
|
Signed-off-by: pranikum <109206473+pranikum@users.noreply.github.com>
Signed-off-by: pranikum <109206473+pranikum@users.noreply.github.com>
Gradle Check (Jenkins) Run Completed with:
|
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.
Lets add assertions in the integration tests for voting configuration values
@@ -39,12 +47,14 @@ public DecommissionRequest(DecommissionAttribute decommissionAttribute) { | |||
public DecommissionRequest(StreamInput in) throws IOException { | |||
super(in); | |||
decommissionAttribute = new DecommissionAttribute(in); | |||
this.delayTimeout = in.readTimeValue(); |
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.
We missed adding noDelay
here. With this no delay would never be read from the request
* Add changes for graceful node decommission Signed-off-by: pranikum <109206473+pranikum@users.noreply.github.com>
* Add changes for graceful node decommission Signed-off-by: pranikum <109206473+pranikum@users.noreply.github.com> Signed-off-by: Rishab Nahata <rnnahata@amazon.com>
* Fail weight update when decommission ongoing and fail decommission when attribute not weighed away (#4839) * Add changes for graceful node decommission (#4586) * Add delay timeout for decommission request (#4931) * Integ Tests for Awareness Attribute Decommissioning (#4715) Signed-off-by: Rishab Nahata <rnnahata@amazon.com> Signed-off-by: pranikum <109206473+pranikum@users.noreply.github.com>
* Fail weight update when decommission ongoing and fail decommission when attribute not weighed away (opensearch-project#4839) * Add changes for graceful node decommission (opensearch-project#4586) * Add delay timeout for decommission request (opensearch-project#4931) * Integ Tests for Awareness Attribute Decommissioning (opensearch-project#4715) Signed-off-by: Rishab Nahata <rnnahata@amazon.com> Signed-off-by: pranikum <109206473+pranikum@users.noreply.github.com>
* Add changes for graceful node decommission Signed-off-by: pranikum <109206473+pranikum@users.noreply.github.com>
Signed-off-by: pranikum 109206473+pranikum@users.noreply.github.com
Description
Changes for graceful decommission of nodes. This includes call to WRR api.
Can be merged once decommission API and WRR changes are merged.
Depends on :
#4272
#4241
Issues Resolved
#4083
Check List
By submitting this pull request, I confirm that my contribution is made under the terms of the Apache 2.0 license.
For more information on following Developer Certificate of Origin and signing off your commits, please check here.