From b299a1a2d5ade1232f53e4aaf94cec505e9efefc Mon Sep 17 00:00:00 2001 From: "opensearch-trigger-bot[bot]" <98922864+opensearch-trigger-bot[bot]@users.noreply.github.com> Date: Fri, 22 Mar 2024 16:35:23 -0700 Subject: [PATCH] Removed log entry regarding destination migration (#1356) (#1493) (cherry picked from commit 48e56bf907ed03c3daeb68cda4e257bd26c02786) Signed-off-by: Riya Saxena Signed-off-by: github-actions[bot] Co-authored-by: github-actions[bot] --- .../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() } }