|
@@ -406,7 +406,11 @@ public class DownsampleActionIT extends ESRestTestCase {
|
|
|
updatePolicy(client(), index, policy);
|
|
|
|
|
|
try {
|
|
|
- assertBusy(() -> assertThat(getStepKeyForIndex(client(), index), equalTo(PhaseCompleteStep.finalStep(phaseName).getKey())));
|
|
|
+ assertBusy(
|
|
|
+ () -> assertThat(getStepKeyForIndex(client(), index), equalTo(PhaseCompleteStep.finalStep(phaseName).getKey())),
|
|
|
+ 120,
|
|
|
+ TimeUnit.SECONDS
|
|
|
+ );
|
|
|
String rollupIndex = getRollupIndexName(client(), index, fixedInterval);
|
|
|
assertNull("Rollup index should not have been created", rollupIndex);
|
|
|
assertTrue("Source index should not have been deleted", indexExists(index));
|