@@ -32,6 +32,7 @@ public final class UnfollowAction implements LifecycleAction {
32
32
33
33
public static final String NAME = "unfollow" ;
34
34
public static final String CCR_METADATA_KEY = "ccr" ;
35
+ static final String OPEN_FOLLOWER_INDEX_STEP_NAME = "open-follower-index" ;
35
36
36
37
public UnfollowAction () {}
37
38
@@ -42,15 +43,17 @@ public List<Step> toSteps(Client client, String phase, StepKey nextStepKey) {
42
43
StepKey pauseFollowerIndex = new StepKey (phase , NAME , PauseFollowerIndexStep .NAME );
43
44
StepKey closeFollowerIndex = new StepKey (phase , NAME , CloseFollowerIndexStep .NAME );
44
45
StepKey unfollowFollowerIndex = new StepKey (phase , NAME , UnfollowFollowerIndexStep .NAME );
45
- StepKey openFollowerIndex = new StepKey (phase , NAME , OpenFollowerIndexStep .NAME );
46
+ // maintaining the `open-follower-index` here (as opposed to {@link OpenIndexStep#NAME}) for BWC reasons (in case any managed
47
+ // index is in the `open-follower-index` step at upgrade time
48
+ StepKey openFollowerIndex = new StepKey (phase , NAME , OPEN_FOLLOWER_INDEX_STEP_NAME );
46
49
StepKey waitForYellowStep = new StepKey (phase , NAME , WaitForIndexColorStep .NAME );
47
50
48
51
WaitForIndexingCompleteStep step1 = new WaitForIndexingCompleteStep (indexingComplete , waitForFollowShardTasks );
49
52
WaitForFollowShardTasksStep step2 = new WaitForFollowShardTasksStep (waitForFollowShardTasks , pauseFollowerIndex , client );
50
53
PauseFollowerIndexStep step3 = new PauseFollowerIndexStep (pauseFollowerIndex , closeFollowerIndex , client );
51
54
CloseFollowerIndexStep step4 = new CloseFollowerIndexStep (closeFollowerIndex , unfollowFollowerIndex , client );
52
55
UnfollowFollowerIndexStep step5 = new UnfollowFollowerIndexStep (unfollowFollowerIndex , openFollowerIndex , client );
53
- OpenFollowerIndexStep step6 = new OpenFollowerIndexStep (openFollowerIndex , waitForYellowStep , client );
56
+ OpenIndexStep step6 = new OpenIndexStep (openFollowerIndex , waitForYellowStep , client );
54
57
WaitForIndexColorStep step7 = new WaitForIndexColorStep (waitForYellowStep , nextStepKey , ClusterHealthStatus .YELLOW );
55
58
return Arrays .asList (step1 , step2 , step3 , step4 , step5 , step6 , step7 );
56
59
}
0 commit comments