fix bug

Signed-off-by: bowenlan-amzn <[email protected]>
opensearch-project · Oct 11, 2023 · a0d88f4 · a0d88f4
1 parent 8b48e04
commit a0d88f4
Showing 1 changed file with 3 additions and 4 deletions.
diff --git a/src/main/kotlin/org/opensearch/indexmanagement/indexstatemanagement/ManagedIndexRunner.kt b/src/main/kotlin/org/opensearch/indexmanagement/indexstatemanagement/ManagedIndexRunner.kt
@@ -464,22 +464,21 @@ object ManagedIndexRunner :
     }
 
     private suspend fun initManagedIndex(managedIndexConfig: ManagedIndexConfig) {
-        var policy: Policy = managedIndexConfig.policy
+        val policy: Policy = managedIndexConfig.policy
         var metadata = getInitializedManagedIndexMetaData(managedIndexConfig, policy, policy.id)
 
         // User may change policy before first metadata initialization
         if (managedIndexConfig.changePolicy != null) {
             val policyID = managedIndexConfig.changePolicy.policyID
             val newPolicy = getPolicy(policyID)
             if (newPolicy != null) {
-                policy = newPolicy
-                val saved = savePolicyToManagedIndexConfig(managedIndexConfig, policy)
+                val saved = savePolicyToManagedIndexConfig(managedIndexConfig, newPolicy)
                 if (!saved) {
                     logger.error("Failed to save policy to ManagedIndexConfig(${managedIndexConfig.index})")
                     return
                 }
             }
-            metadata = getInitializedManagedIndexMetaData(managedIndexConfig, policy, policyID)
+            metadata = getInitializedManagedIndexMetaData(managedIndexConfig, newPolicy, policyID)
         }
 
         updateManagedIndexMetaData(metadata, create = true)