diff --git a/src/main/kotlin/org/opensearch/indexmanagement/indexstatemanagement/ManagedIndexCoordinator.kt b/src/main/kotlin/org/opensearch/indexmanagement/indexstatemanagement/ManagedIndexCoordinator.kt index eeeeb5252..cfb66a462 100644 --- a/src/main/kotlin/org/opensearch/indexmanagement/indexstatemanagement/ManagedIndexCoordinator.kt +++ b/src/main/kotlin/org/opensearch/indexmanagement/indexstatemanagement/ManagedIndexCoordinator.kt @@ -262,6 +262,11 @@ class ManagedIndexCoordinator( */ @OpenForTesting suspend fun sweepClusterChangedEvent(event: ClusterChangedEvent) { + // If IM config doesn't exist skip + if (!ismIndices.indexManagementIndexExists()) { + logger.debug("[.opendistro-ism-config] config index does not exist") + return + } // indices delete event var removeManagedIndexReq = emptyList>() var indicesToClean = emptyList()