[Test] Fix SnapshotShardsServiceIT.testRetryPostingSnapshotStatusMessages

This test requires a bit more time than 10 seconds for the the snapshot
to be completed, it is now 30s.

Closes #29270
This commit is contained in:
Tanguy Leroux 2018-04-06 10:24:55 +02:00
parent 7d29087442
commit ae2a9f7108
1 changed files with 2 additions and 2 deletions

View File

@ -96,7 +96,7 @@ public class SnapshotShardsServiceIT extends AbstractSnapshotIntegTestCase {
.values().stream().map(status -> status.asCopy().getStage()).collect(Collectors.toList()); .values().stream().map(status -> status.asCopy().getStage()).collect(Collectors.toList());
assertThat(stages, hasSize(shards)); assertThat(stages, hasSize(shards));
assertThat(stages, everyItem(equalTo(IndexShardSnapshotStatus.Stage.DONE))); assertThat(stages, everyItem(equalTo(IndexShardSnapshotStatus.Stage.DONE)));
}); }, 30L, TimeUnit.SECONDS);
logger.info("--> stop disrupting cluster"); logger.info("--> stop disrupting cluster");
networkDisruption.stopDisrupting(); networkDisruption.stopDisrupting();
@ -110,6 +110,6 @@ public class SnapshotShardsServiceIT extends AbstractSnapshotIntegTestCase {
logger.info("Snapshot status [{}], successfulShards [{}]", snapshotInfo.state(), snapshotInfo.successfulShards()); logger.info("Snapshot status [{}], successfulShards [{}]", snapshotInfo.state(), snapshotInfo.successfulShards());
assertThat(snapshotInfo.state(), equalTo(SnapshotState.SUCCESS)); assertThat(snapshotInfo.state(), equalTo(SnapshotState.SUCCESS));
assertThat(snapshotInfo.successfulShards(), equalTo(shards)); assertThat(snapshotInfo.successfulShards(), equalTo(shards));
}, 10, TimeUnit.SECONDS); }, 30L, TimeUnit.SECONDS);
} }
} }