Skip to content

Commit

Permalink
Remove white spaces
Browse files Browse the repository at this point in the history
Signed-off-by: Rishab Nahata <rnnahata@amazon.com>
  • Loading branch information
imRishN committed Nov 5, 2022
1 parent a8d4fd6 commit 14b5c38
Showing 1 changed file with 0 additions and 7 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -140,24 +140,17 @@ public void startDecommissionAction(
final DecommissionAttribute decommissionAttribute = decommissionRequest.getDecommissionAttribute();
// register the metadata with status as INIT as first step
clusterService.submitStateUpdateTask("decommission [" + decommissionAttribute + "]", new ClusterStateUpdateTask(Priority.URGENT) {

private Set<String> nodeIdsToBeExcluded;

@Override
public ClusterState execute(ClusterState currentState) {
// validates if correct awareness attributes and forced awareness attribute set to the cluster before starting action
validateAwarenessAttribute(decommissionAttribute, awarenessAttributes, forcedAwarenessAttributes);

DecommissionAttributeMetadata decommissionAttributeMetadata = currentState.metadata().decommissionAttributeMetadata();

// check that request is eligible to proceed
ensureEligibleRequest(decommissionAttributeMetadata, decommissionAttribute);

// ensure attribute is weighed away
ensureToBeDecommissionedAttributeWeighedAway(currentState, decommissionAttribute);

ClusterState newState = registerDecommissionAttributeInClusterState(currentState, decommissionAttribute);

Set<DiscoveryNode> clusterManagerNodesToBeDecommissioned = filterNodesWithDecommissionAttribute(
currentState,
decommissionAttribute,
Expand Down

0 comments on commit 14b5c38

Please sign in to comment.