@@ -142,7 +142,7 @@ public void testIndexDataTierMigration() throws Exception {
142
142
IndexLifecycleExplainResponse indexLifecycleExplainResponse = explainResponse .getIndexResponses ().get (managedIndex );
143
143
assertThat (indexLifecycleExplainResponse .getPhase (), is ("warm" ));
144
144
assertThat (indexLifecycleExplainResponse .getStep (), is (DataTierMigrationRoutedStep .NAME ));
145
- });
145
+ }, 30 , TimeUnit . SECONDS );
146
146
147
147
logger .info ("starting a warm data node" );
148
148
internalCluster ().startNode (warmNode (Settings .EMPTY ));
@@ -154,7 +154,7 @@ public void testIndexDataTierMigration() throws Exception {
154
154
IndexLifecycleExplainResponse indexLifecycleExplainResponse = explainResponse .getIndexResponses ().get (managedIndex );
155
155
assertThat (indexLifecycleExplainResponse .getPhase (), is ("cold" ));
156
156
assertThat (indexLifecycleExplainResponse .getStep (), is (DataTierMigrationRoutedStep .NAME ));
157
- });
157
+ }, 30 , TimeUnit . SECONDS );
158
158
159
159
logger .info ("starting a cold data node" );
160
160
internalCluster ().startNode (coldNode (Settings .EMPTY ));
@@ -168,7 +168,7 @@ public void testIndexDataTierMigration() throws Exception {
168
168
IndexLifecycleExplainResponse indexLifecycleExplainResponse = explainResponse .getIndexResponses ().get (managedIndex );
169
169
assertThat (indexLifecycleExplainResponse .getPhase (), is ("cold" ));
170
170
assertThat (indexLifecycleExplainResponse .getStep (), is ("complete" ));
171
- });
171
+ }, 30 , TimeUnit . SECONDS );
172
172
}
173
173
174
174
public void testUserOptsOutOfTierMigration () throws Exception {
0 commit comments