From 0602f9be64f39eef3375aa178c247c3cca582f48 Mon Sep 17 00:00:00 2001 From: Ronnak Saxena Date: Fri, 7 Jul 2023 11:58:06 -0700 Subject: [PATCH 1/3] Does not sweep if cluster doesn't contain an ISM Config Index Signed-off-by: Ronnak Saxena --- .../indexstatemanagement/ManagedIndexCoordinator.kt | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/src/main/kotlin/org/opensearch/indexmanagement/indexstatemanagement/ManagedIndexCoordinator.kt b/src/main/kotlin/org/opensearch/indexmanagement/indexstatemanagement/ManagedIndexCoordinator.kt index eeeeb5252..bba611684 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.info("[.opendistro-ism-config] index had not been created") + return + } // indices delete event var removeManagedIndexReq = emptyList>() var indicesToClean = emptyList() From 9afda71ea5363164e628ab2870a5f0fa3e650fc6 Mon Sep 17 00:00:00 2001 From: Ronnak Saxena Date: Fri, 7 Jul 2023 14:22:12 -0700 Subject: [PATCH 2/3] fixed the warn message Signed-off-by: Ronnak Saxena --- .../indexstatemanagement/ManagedIndexCoordinator.kt | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/kotlin/org/opensearch/indexmanagement/indexstatemanagement/ManagedIndexCoordinator.kt b/src/main/kotlin/org/opensearch/indexmanagement/indexstatemanagement/ManagedIndexCoordinator.kt index bba611684..8df5f6a61 100644 --- a/src/main/kotlin/org/opensearch/indexmanagement/indexstatemanagement/ManagedIndexCoordinator.kt +++ b/src/main/kotlin/org/opensearch/indexmanagement/indexstatemanagement/ManagedIndexCoordinator.kt @@ -264,7 +264,7 @@ class ManagedIndexCoordinator( suspend fun sweepClusterChangedEvent(event: ClusterChangedEvent) { // If IM config doesn't exist skip if (!ismIndices.indexManagementIndexExists()) { - logger.info("[.opendistro-ism-config] index had not been created") + logger.warn("[.opendistro-ism-config] config index does not exist") return } // indices delete event From 1df22904367d9d65ddc20d7fd675367afb7ffa06 Mon Sep 17 00:00:00 2001 From: Ronnak Saxena Date: Fri, 7 Jul 2023 16:09:51 -0700 Subject: [PATCH 3/3] changed log from warn to debug Signed-off-by: Ronnak Saxena --- .../indexstatemanagement/ManagedIndexCoordinator.kt | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/kotlin/org/opensearch/indexmanagement/indexstatemanagement/ManagedIndexCoordinator.kt b/src/main/kotlin/org/opensearch/indexmanagement/indexstatemanagement/ManagedIndexCoordinator.kt index 8df5f6a61..cfb66a462 100644 --- a/src/main/kotlin/org/opensearch/indexmanagement/indexstatemanagement/ManagedIndexCoordinator.kt +++ b/src/main/kotlin/org/opensearch/indexmanagement/indexstatemanagement/ManagedIndexCoordinator.kt @@ -264,7 +264,7 @@ class ManagedIndexCoordinator( suspend fun sweepClusterChangedEvent(event: ClusterChangedEvent) { // If IM config doesn't exist skip if (!ismIndices.indexManagementIndexExists()) { - logger.warn("[.opendistro-ism-config] config index does not exist") + logger.debug("[.opendistro-ism-config] config index does not exist") return } // indices delete event