diff --git a/src/test/kotlin/org/opensearch/indexmanagement/indexstatemanagement/IndexStateManagementRestTestCase.kt b/src/test/kotlin/org/opensearch/indexmanagement/indexstatemanagement/IndexStateManagementRestTestCase.kt index ddb510488..ab8e772a2 100644 --- a/src/test/kotlin/org/opensearch/indexmanagement/indexstatemanagement/IndexStateManagementRestTestCase.kt +++ b/src/test/kotlin/org/opensearch/indexmanagement/indexstatemanagement/IndexStateManagementRestTestCase.kt @@ -476,8 +476,6 @@ abstract class IndexStateManagementRestTestCase : IndexManagementRestTestCase() protected fun ExplainFilter.toHttpEntity(): HttpEntity = StringEntity(toJsonString(), APPLICATION_JSON) - protected fun ExplainFilter.toHttpEntity(): HttpEntity = StringEntity(toJsonString(), ContentType.APPLICATION_JSON) - protected fun ChangePolicy.toHttpEntity(): HttpEntity { var string = "{\"${ChangePolicy.POLICY_ID_FIELD}\":\"$policyID\"," if (state != null) { diff --git a/src/test/kotlin/org/opensearch/indexmanagement/indexstatemanagement/resthandler/RestExplainActionIT.kt b/src/test/kotlin/org/opensearch/indexmanagement/indexstatemanagement/resthandler/RestExplainActionIT.kt index 5c91f9364..c0842adbf 100644 --- a/src/test/kotlin/org/opensearch/indexmanagement/indexstatemanagement/resthandler/RestExplainActionIT.kt +++ b/src/test/kotlin/org/opensearch/indexmanagement/indexstatemanagement/resthandler/RestExplainActionIT.kt @@ -500,6 +500,9 @@ class RestExplainActionIT : IndexStateManagementRestTestCase() { removePolicyFromIndex(indexName1) removePolicyFromIndex(indexName2) + + // wait for job to finish + Thread.sleep(1000) } fun `test explain filter failed index`() { @@ -607,6 +610,9 @@ class RestExplainActionIT : IndexStateManagementRestTestCase() { removePolicyFromIndex(indexName1) removePolicyFromIndex(indexName2) + + // wait for job to finish + Thread.sleep(1000) } @Suppress("UNCHECKED_CAST") // Do assertion of the response map here so we don't have many places to do suppression.