|
|
@@ -163,16 +163,16 @@ public class TimeSeriesLifecycleActionsIT extends ESRestTestCase {
|
|
|
}
|
|
|
|
|
|
|
|
|
- @AwaitsFix(bugUrl = "https://github.com/elastic/elasticsearch/issues/69340")
|
|
|
public void testAllocateOnlyAllocation() throws Exception {
|
|
|
createIndexWithSettings(client(), index, alias, Settings.builder().put(IndexMetadata.SETTING_NUMBER_OF_SHARDS, 2)
|
|
|
.put(IndexMetadata.SETTING_NUMBER_OF_REPLICAS, 0));
|
|
|
- String allocateNodeName = "javaRestTest-" + randomFrom(0, 1);
|
|
|
- AllocateAction allocateAction = new AllocateAction(null, null, null, singletonMap("_name", allocateNodeName));
|
|
|
+ String allocateNodeName = "javaRestTest-0,javaRestTest-1,javaRestTest-2,javaRestTest-3";
|
|
|
+ AllocateAction allocateAction = new AllocateAction(null, singletonMap("_name", allocateNodeName), null, null);
|
|
|
String endPhase = randomFrom("warm", "cold");
|
|
|
createNewSingletonPolicy(client(), policy, endPhase, allocateAction);
|
|
|
updatePolicy(client(), index, policy);
|
|
|
- assertBusy(() -> assertThat(getStepKeyForIndex(client(), index), equalTo(PhaseCompleteStep.finalStep(endPhase).getKey())));
|
|
|
+ assertBusy(() -> assertThat(getStepKeyForIndex(client(), index), equalTo(PhaseCompleteStep.finalStep(endPhase).getKey())),
|
|
|
+ 30, TimeUnit.SECONDS);
|
|
|
ensureGreen(index);
|
|
|
}
|
|
|
|