From 48e56bf907ed03c3daeb68cda4e257bd26c02786 Mon Sep 17 00:00:00 2001 From: Riya <69919272+riysaxen-amzn@users.noreply.github.com> Date: Mon, 8 Jan 2024 12:07:41 -0800 Subject: [PATCH] Removed log entry regarding destination migration (#1356) 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() } }