From 4ed438629b0f406577961ead3b0333f34fcf8f51 Mon Sep 17 00:00:00 2001 From: Riya Saxena Date: Thu, 28 Dec 2023 19:09:47 -0800 Subject: [PATCH] Removed log entry regarding destination migration Signed-off-by: Riya Saxena --- .../destinationmigration/DestinationMigrationCoordinator.kt | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/alerting/src/main/kotlin/org/opensearch/alerting/util/destinationmigration/DestinationMigrationCoordinator.kt b/alerting/src/main/kotlin/org/opensearch/alerting/util/destinationmigration/DestinationMigrationCoordinator.kt index 82891396e..fbb3b1527 100644 --- a/alerting/src/main/kotlin/org/opensearch/alerting/util/destinationmigration/DestinationMigrationCoordinator.kt +++ b/alerting/src/main/kotlin/org/opensearch/alerting/util/destinationmigration/DestinationMigrationCoordinator.kt @@ -45,7 +45,6 @@ class DestinationMigrationCoordinator( } override fun clusterChanged(event: ClusterChangedEvent) { - logger.info("Detected cluster change event for destination migration") if (DestinationMigrationUtilService.finishFlag) { logger.info("Reset destination migration process.") scheduledMigration?.cancel() @@ -63,6 +62,7 @@ class DestinationMigrationCoordinator( runningLock = false } } else if (!event.localNodeClusterManager()) { + logger.info("Cancelling the migration process.") scheduledMigration?.cancel() } }