Execute PluginVersionSweepCoordinator on GENERIC threadpool

Signed-off-by: Rohit Ashiwal <[email protected]>
opensearch-project · Jun 20, 2024 · 5dda370 · 5dda370
1 parent 52f331f
commit 5dda370
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/...tlin/org/opensearch/indexmanagement/indexstatemanagement/PluginVersionSweepCoordinator.kt b/...tlin/org/opensearch/indexmanagement/indexstatemanagement/PluginVersionSweepCoordinator.kt
@@ -58,8 +58,10 @@ class PluginVersionSweepCoordinator(
 
     override fun clusterChanged(event: ClusterChangedEvent) {
         if (event.nodesChanged() || event.isNewCluster) {
-            skipExecution.sweepISMPluginVersion()
-            initBackgroundSweepISMPluginVersionExecution()
+            threadPool.generic().execute {
+                skipExecution.sweepISMPluginVersion()
+                initBackgroundSweepISMPluginVersionExecution()
+            }
         }
     }
 
@@ -85,7 +87,7 @@ class PluginVersionSweepCoordinator(
                 }
             }
         scheduledSkipExecution =
-            threadPool.scheduleWithFixedDelay(scheduledJob, sweepSkipPeriod, ThreadPool.Names.MANAGEMENT)
+            threadPool.scheduleWithFixedDelay(scheduledJob, sweepSkipPeriod, ThreadPool.Names.GENERIC)
     }
 
     private fun isIndexStateManagementEnabled(): Boolean = indexStateManagementEnabled == true