Skip to content

Commit

Permalink
Fix SnapshotDisruptionIT by renaming to cluster-manager
Browse files Browse the repository at this point in the history
Signed-off-by: Tianli Feng <ftianli@amazon.com>
  • Loading branch information
Tianli Feng committed Apr 26, 2022
1 parent 4d50c6f commit cc57d7e
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -248,7 +248,7 @@ public void testMasterFailOverDuringShardSnapshots() throws Exception {

blockDataNode(repoName, dataNode);

logger.info("--> create snapshot via master node client");
logger.info("--> create snapshot via cluster-manager node client");
final ActionFuture<CreateSnapshotResponse> snapshotResponse = internalCluster().masterClient()
.admin()
.cluster()
Expand All @@ -272,7 +272,7 @@ public void testMasterFailOverDuringShardSnapshots() throws Exception {
SnapshotException.class,
() -> snapshotResponse.actionGet(TimeValue.timeValueSeconds(30L))
);
assertThat(sne.getMessage(), endsWith("no longer master"));
assertThat(sne.getMessage(), endsWith("no longer cluster-manager"));
}

private void assertSnapshotExists(String repository, String snapshot) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -509,7 +509,7 @@ public void testLeaderBehaviour() {
CoordinationStateRejectedException cause = (CoordinationStateRejectedException) handler.transportException.getRootCause();
assertThat(
cause.getMessage(),
equalTo("rejecting leader check from [" + otherNode + "] sent to a node that is no longer the master")
equalTo("rejecting leader check from [" + otherNode + "] sent to a node that is no longer the cluster-manager")
);
}
}
Expand Down

0 comments on commit cc57d7e

Please sign in to comment.