parent
598d4c1bf9
commit
df0ad7569b
|
@ -10,6 +10,7 @@ import org.apache.http.entity.ContentType;
|
||||||
import org.apache.http.entity.StringEntity;
|
import org.apache.http.entity.StringEntity;
|
||||||
import org.apache.logging.log4j.LogManager;
|
import org.apache.logging.log4j.LogManager;
|
||||||
import org.apache.logging.log4j.Logger;
|
import org.apache.logging.log4j.Logger;
|
||||||
|
import org.apache.lucene.util.LuceneTestCase;
|
||||||
import org.elasticsearch.client.Request;
|
import org.elasticsearch.client.Request;
|
||||||
import org.elasticsearch.client.Response;
|
import org.elasticsearch.client.Response;
|
||||||
import org.elasticsearch.client.ResponseException;
|
import org.elasticsearch.client.ResponseException;
|
||||||
|
@ -75,6 +76,7 @@ import static org.hamcrest.Matchers.is;
|
||||||
import static org.hamcrest.Matchers.not;
|
import static org.hamcrest.Matchers.not;
|
||||||
import static org.hamcrest.Matchers.nullValue;
|
import static org.hamcrest.Matchers.nullValue;
|
||||||
|
|
||||||
|
@LuceneTestCase.AwaitsFix(bugUrl = "https://github.com/elastic/elasticsearch/issues/53738")
|
||||||
public class TimeSeriesLifecycleActionsIT extends ESRestTestCase {
|
public class TimeSeriesLifecycleActionsIT extends ESRestTestCase {
|
||||||
private static final Logger logger = LogManager.getLogger(TimeSeriesLifecycleActionsIT.class);
|
private static final Logger logger = LogManager.getLogger(TimeSeriesLifecycleActionsIT.class);
|
||||||
private static final String FAILED_STEP_RETRY_COUNT_FIELD = "failed_step_retry_count";
|
private static final String FAILED_STEP_RETRY_COUNT_FIELD = "failed_step_retry_count";
|
||||||
|
@ -94,7 +96,7 @@ public class TimeSeriesLifecycleActionsIT extends ESRestTestCase {
|
||||||
public static void updatePolicy(String indexName, String policy) throws IOException {
|
public static void updatePolicy(String indexName, String policy) throws IOException {
|
||||||
Request changePolicyRequest = new Request("PUT", "/" + indexName + "/_settings");
|
Request changePolicyRequest = new Request("PUT", "/" + indexName + "/_settings");
|
||||||
final StringEntity changePolicyEntity = new StringEntity("{ \"index.lifecycle.name\": \"" + policy + "\" }",
|
final StringEntity changePolicyEntity = new StringEntity("{ \"index.lifecycle.name\": \"" + policy + "\" }",
|
||||||
ContentType.APPLICATION_JSON);
|
ContentType.APPLICATION_JSON);
|
||||||
changePolicyRequest.setEntity(changePolicyEntity);
|
changePolicyRequest.setEntity(changePolicyEntity);
|
||||||
assertOK(client().performRequest(changePolicyRequest));
|
assertOK(client().performRequest(changePolicyRequest));
|
||||||
}
|
}
|
||||||
|
@ -655,9 +657,9 @@ public class TimeSeriesLifecycleActionsIT extends ESRestTestCase {
|
||||||
createIndexWithSettings(index, Settings.builder().put(IndexMetaData.SETTING_NUMBER_OF_SHARDS, numShards)
|
createIndexWithSettings(index, Settings.builder().put(IndexMetaData.SETTING_NUMBER_OF_SHARDS, numShards)
|
||||||
.put(IndexMetaData.SETTING_NUMBER_OF_REPLICAS, 0));
|
.put(IndexMetaData.SETTING_NUMBER_OF_REPLICAS, 0));
|
||||||
|
|
||||||
ensureGreen(index);
|
ensureGreen(index);
|
||||||
|
|
||||||
// unallocate all index shards
|
// unallocate all index shards
|
||||||
Request setAllocationToMissingAttribute = new Request("PUT", "/" + index + "/_settings");
|
Request setAllocationToMissingAttribute = new Request("PUT", "/" + index + "/_settings");
|
||||||
setAllocationToMissingAttribute.setJsonEntity("{\n" +
|
setAllocationToMissingAttribute.setJsonEntity("{\n" +
|
||||||
" \"settings\": {\n" +
|
" \"settings\": {\n" +
|
||||||
|
@ -1335,8 +1337,8 @@ public class TimeSeriesLifecycleActionsIT extends ESRestTestCase {
|
||||||
String originalIndex = index + "-000001";
|
String originalIndex = index + "-000001";
|
||||||
String secondIndex = index + "-000002";
|
String secondIndex = index + "-000002";
|
||||||
createIndexWithSettings(originalIndex, Settings.builder().put(IndexMetaData.SETTING_NUMBER_OF_SHARDS, 1)
|
createIndexWithSettings(originalIndex, Settings.builder().put(IndexMetaData.SETTING_NUMBER_OF_SHARDS, 1)
|
||||||
.put(IndexMetaData.SETTING_NUMBER_OF_REPLICAS, 0)
|
.put(IndexMetaData.SETTING_NUMBER_OF_REPLICAS, 0)
|
||||||
.put(RolloverAction.LIFECYCLE_ROLLOVER_ALIAS, alias),
|
.put(RolloverAction.LIFECYCLE_ROLLOVER_ALIAS, alias),
|
||||||
true);
|
true);
|
||||||
|
|
||||||
// create policy
|
// create policy
|
||||||
|
@ -1813,7 +1815,7 @@ public class TimeSeriesLifecycleActionsIT extends ESRestTestCase {
|
||||||
.field("repository", repo)
|
.field("repository", repo)
|
||||||
.field("name", "snap" + randomAlphaOfLengthBetween(5, 10).toLowerCase(Locale.ROOT))
|
.field("name", "snap" + randomAlphaOfLengthBetween(5, 10).toLowerCase(Locale.ROOT))
|
||||||
.startObject("config")
|
.startObject("config")
|
||||||
.field("include_global_state", false)
|
.field("include_global_state", false)
|
||||||
.endObject()
|
.endObject()
|
||||||
.endObject()));
|
.endObject()));
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue