@@ -216,8 +216,8 @@ public void testUpgradeDataStream() throws Exception {
216216 enableILM ();
217217 }
218218 Map <String , Map <String , Object >> oldIndicesMetadata = getIndicesMetadata (dataStreamName );
219- upgradeDataStream (dataStreamName , numRollovers , numRollovers + 1 , 0 );
220- upgradeDataStream (dataStreamFromNonDataStreamIndices , 0 , 1 , 0 );
219+ upgradeDataStream (dataStreamName , numRollovers , numRollovers + 1 , 0 , ilmEnabled );
220+ upgradeDataStream (dataStreamFromNonDataStreamIndices , 0 , 1 , 0 , ilmEnabled );
221221 Map <String , Map <String , Object >> upgradedIndicesMetadata = getIndicesMetadata (dataStreamName );
222222
223223 if (ilmEnabled ) {
@@ -269,7 +269,7 @@ private void checkILMPhase(String dataStreamName, Map<String, Map<String, Object
269269 assertThat ("Index has not moved to cold ILM phase" , ilmInfo .get ("phase" ), equalTo ("cold" ));
270270 }
271271 }
272- });
272+ }, 30 , TimeUnit . SECONDS );
273273 }
274274
275275 private String getWriteIndexFromDataStreamIndexMetadata (Map <String , Map <String , Object >> indexMetadataForDataStream ) {
@@ -581,13 +581,13 @@ private void createDataStreamFromNonDataStreamIndices(String dataStreamFromNonDa
581581 }
582582
583583 @ SuppressWarnings ("unchecked" )
584- private void upgradeDataStream (String dataStreamName , int numRolloversOnOldCluster , int expectedSuccessesCount , int expectedErrorCount )
584+ private void upgradeDataStream (String dataStreamName , int numRolloversOnOldCluster , int expectedSuccessesCount , int expectedErrorCount , boolean ilmEnabled )
585585 throws Exception {
586586 Set <String > indicesNeedingUpgrade = getDataStreamIndices (dataStreamName );
587587 final int explicitRolloverOnNewClusterCount = randomIntBetween (0 , 2 );
588588 for (int i = 0 ; i < explicitRolloverOnNewClusterCount ; i ++) {
589589 String oldIndexName = rollover (dataStreamName );
590- if (randomBoolean ()) {
590+ if (ilmEnabled == false && randomBoolean ()) {
591591 closeIndex (oldIndexName );
592592 }
593593 }
0 commit comments