diff --git a/src/main/kotlin/org/opensearch/indexmanagement/indexstatemanagement/ManagedIndexCoordinator.kt b/src/main/kotlin/org/opensearch/indexmanagement/indexstatemanagement/ManagedIndexCoordinator.kt index bb286ea9e..efe94ec22 100644 --- a/src/main/kotlin/org/opensearch/indexmanagement/indexstatemanagement/ManagedIndexCoordinator.kt +++ b/src/main/kotlin/org/opensearch/indexmanagement/indexstatemanagement/ManagedIndexCoordinator.kt @@ -292,6 +292,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()