10
10
import org .apache .http .entity .StringEntity ;
11
11
import org .apache .logging .log4j .LogManager ;
12
12
import org .apache .logging .log4j .Logger ;
13
+ import org .apache .lucene .util .LuceneTestCase ;
13
14
import org .elasticsearch .client .Request ;
14
15
import org .elasticsearch .client .Response ;
15
16
import org .elasticsearch .client .ResponseException ;
75
76
import static org .hamcrest .Matchers .not ;
76
77
import static org .hamcrest .Matchers .nullValue ;
77
78
79
+ @ LuceneTestCase .AwaitsFix (bugUrl = "https://github.com/elastic/elasticsearch/issues/53738" )
78
80
public class TimeSeriesLifecycleActionsIT extends ESRestTestCase {
79
81
private static final Logger logger = LogManager .getLogger (TimeSeriesLifecycleActionsIT .class );
80
82
private static final String FAILED_STEP_RETRY_COUNT_FIELD = "failed_step_retry_count" ;
@@ -94,7 +96,7 @@ public void refreshIndex() {
94
96
public static void updatePolicy (String indexName , String policy ) throws IOException {
95
97
Request changePolicyRequest = new Request ("PUT" , "/" + indexName + "/_settings" );
96
98
final StringEntity changePolicyEntity = new StringEntity ("{ \" index.lifecycle.name\" : \" " + policy + "\" }" ,
97
- ContentType .APPLICATION_JSON );
99
+ ContentType .APPLICATION_JSON );
98
100
changePolicyRequest .setEntity (changePolicyEntity );
99
101
assertOK (client ().performRequest (changePolicyRequest ));
100
102
}
@@ -655,9 +657,9 @@ public void testSetSingleNodeAllocationRetriesUntilItSucceeds() throws Exception
655
657
createIndexWithSettings (index , Settings .builder ().put (IndexMetaData .SETTING_NUMBER_OF_SHARDS , numShards )
656
658
.put (IndexMetaData .SETTING_NUMBER_OF_REPLICAS , 0 ));
657
659
658
- ensureGreen (index );
660
+ ensureGreen (index );
659
661
660
- // unallocate all index shards
662
+ // unallocate all index shards
661
663
Request setAllocationToMissingAttribute = new Request ("PUT" , "/" + index + "/_settings" );
662
664
setAllocationToMissingAttribute .setJsonEntity ("{\n " +
663
665
" \" settings\" : {\n " +
@@ -1335,8 +1337,8 @@ public void testWaitForActiveShardsStep() throws Exception {
1335
1337
String originalIndex = index + "-000001" ;
1336
1338
String secondIndex = index + "-000002" ;
1337
1339
createIndexWithSettings (originalIndex , Settings .builder ().put (IndexMetaData .SETTING_NUMBER_OF_SHARDS , 1 )
1338
- .put (IndexMetaData .SETTING_NUMBER_OF_REPLICAS , 0 )
1339
- .put (RolloverAction .LIFECYCLE_ROLLOVER_ALIAS , alias ),
1340
+ .put (IndexMetaData .SETTING_NUMBER_OF_REPLICAS , 0 )
1341
+ .put (RolloverAction .LIFECYCLE_ROLLOVER_ALIAS , alias ),
1340
1342
true );
1341
1343
1342
1344
// create policy
@@ -1813,7 +1815,7 @@ private void createSlmPolicy(String smlPolicy, String repo) throws IOException {
1813
1815
.field ("repository" , repo )
1814
1816
.field ("name" , "snap" + randomAlphaOfLengthBetween (5 , 10 ).toLowerCase (Locale .ROOT ))
1815
1817
.startObject ("config" )
1816
- .field ("include_global_state" , false )
1818
+ .field ("include_global_state" , false )
1817
1819
.endObject ()
1818
1820
.endObject ()));
1819
1821
0 commit comments