From a965229f9cf23fcb6431ab33d53b1546dd2899e6 Mon Sep 17 00:00:00 2001 From: Sean Kao Date: Tue, 19 Mar 2024 14:36:31 -0700 Subject: [PATCH] remove unnecessary log Signed-off-by: Sean Kao --- .../main/scala/org/opensearch/flint/spark/FlintSpark.scala | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-) diff --git a/flint-spark-integration/src/main/scala/org/opensearch/flint/spark/FlintSpark.scala b/flint-spark-integration/src/main/scala/org/opensearch/flint/spark/FlintSpark.scala index 5b9b8e6d3..34327bebb 100644 --- a/flint-spark-integration/src/main/scala/org/opensearch/flint/spark/FlintSpark.scala +++ b/flint-spark-integration/src/main/scala/org/opensearch/flint/spark/FlintSpark.scala @@ -391,10 +391,7 @@ class FlintSpark(val spark: SparkSession) extends Logging { .startTransaction(indexName, dataSourceName) .initialLog(latest => latest.state == REFRESHING) .transientLog(latest => latest.copy(state = UPDATING)) - .finalLog(latest => { - logInfo("Updating index state to active") - latest.copy(state = ACTIVE) - }) + .finalLog(latest => latest.copy(state = ACTIVE)) .commit(_ => { flintClient.updateIndex(indexName, index.metadata) logInfo("Update index options complete") @@ -415,7 +412,6 @@ class FlintSpark(val spark: SparkSession) extends Logging { .finalLog(latest => { logInfo("Scheduling index state monitor") flintIndexMonitor.startMonitor(indexName) - logInfo("Updating index state to refreshing") latest.copy(state = REFRESHING) }) .commit(_ => {