From 17d11dea5259d2267d6004f67ec1eddaf35c1c0f Mon Sep 17 00:00:00 2001 From: Ronnak Saxena Date: Fri, 29 Jul 2022 18:34:49 +0000 Subject: [PATCH] removed print statements Signed-off-by: Ronnak Saxena --- .../indexstatemanagement/ManagedIndexRunner.kt | 13 ++----------- 1 file changed, 2 insertions(+), 11 deletions(-) diff --git a/src/main/kotlin/org/opensearch/indexmanagement/indexstatemanagement/ManagedIndexRunner.kt b/src/main/kotlin/org/opensearch/indexmanagement/indexstatemanagement/ManagedIndexRunner.kt index 5d350bbd7..5eabb710d 100644 --- a/src/main/kotlin/org/opensearch/indexmanagement/indexstatemanagement/ManagedIndexRunner.kt +++ b/src/main/kotlin/org/opensearch/indexmanagement/indexstatemanagement/ManagedIndexRunner.kt @@ -229,7 +229,6 @@ object ManagedIndexRunner : var keepExecuting: Boolean = true // Need to execute at least once for policy to initialize do { - println("RON SAX LOOK HERE: name: ${job.jobName} continuous: ${job.continuous}, keepExecuting: $keepExecuting, id: ${job.id}") // Need to renew lock for current step execution val renewedLock = renewLockForScheduledJob(context, lock as LockModel, errorNotificationRetryPolicy) // Failed to renew lock @@ -242,7 +241,6 @@ object ManagedIndexRunner : } } while ((job.continuous && keepExecuting)) // Runs until job is no longer continuous or execution should stop } else { // If job is not continuous run once - println("RON SAX LOOK HERE: name: ${job.jobName} continuous: ${job.continuous}, id: ${job.id}") runManagedIndexConfig(job, context) } // Release lock @@ -322,7 +320,6 @@ object ManagedIndexRunner : if (result.metadataSaved) { disableManagedIndexConfig(managedIndexConfig) } - println("RON SAX return false in line 324") return false } @@ -355,10 +352,8 @@ object ManagedIndexRunner : if (managedIndexConfig.shouldChangePolicy(managedIndexMetaData, action)) { return if (initChangePolicy(managedIndexConfig, managedIndexMetaData, action)) { // Don't want to continue execution on old Managed Index Config - println("RON SAX: returned false on 357") false } else { - print("RON SAX returned false on 361") // Managed index config was not updated to safe to continue execution of this job true } @@ -426,12 +421,9 @@ object ManagedIndexRunner : managedIndexConfig.id, settings, threadPool.threadContext, managedIndexConfig.policy.user ) ) { - println("RON SAX STEP: ${step.name}") step.preExecute(logger, stepContext.getUpdatedContext(startingManagedIndexMetaData)).execute().postExecute(logger) } - println("RON SAX Starting metadata: $startingManagedIndexMetaData") var executedManagedIndexMetaData = startingManagedIndexMetaData.getCompletedManagedIndexMetaData(action, step) - println("RON SAX executed metadata: $executedManagedIndexMetaData") if (executedManagedIndexMetaData.isFailed) { try { @@ -474,7 +466,6 @@ object ManagedIndexRunner : return false } // Made it to end of successful execution block - println("RON SAX: returned true on 478") return true } return false @@ -560,9 +551,9 @@ object ManagedIndexRunner : savedPolicy = indexResponse.status() == RestStatus.OK } } catch (e: VersionConflictEngineException) { - logger.error("RON SAX VERSION CONFLICT Failed to save policy(${policy.id}) to ManagedIndexConfig(${managedIndexConfig.index}). ${e.message}") + logger.error("Failed to save policy(${policy.id}) to ManagedIndexConfig(${managedIndexConfig.index}). ${e.message}") } catch (e: Exception) { - logger.error("RON SAX OTHER EXCEPTION Failed to save policy(${policy.id}) to ManagedIndexConfig(${managedIndexConfig.index})", e) + logger.error("Failed to save policy(${policy.id}) to ManagedIndexConfig(${managedIndexConfig.index})", e) } return savedPolicy }