move transformedDocs into for loop in fetchDataAndExecutePercolateQue…

…riesPerShard() Signed-off-by: Surya Sashank Nistala <[email protected]>
opensearch-project · Dec 20, 2023 · c97b8fb · c97b8fb
1 parent f4c3690
commit c97b8fb
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/alerting/src/main/kotlin/org/opensearch/alerting/DocumentLevelMonitorRunner.kt b/alerting/src/main/kotlin/org/opensearch/alerting/DocumentLevelMonitorRunner.kt
@@ -596,8 +596,8 @@ object DocumentLevelMonitorRunner : MonitorRunner() {
         docsToQueries: MutableMap<String, MutableList<String>>,
     ) {
         val count: Int = docExecutionCtx.updatedLastRunContext["shards_count"] as Int
-        val transformedDocs = mutableListOf<Pair<String, BytesReference>>()
         for (i: Int in 0 until count) {
+            val transformedDocs = mutableListOf<Pair<String, BytesReference>>()
             val shard = i.toString()
             try {
                 val maxSeqNo: Long = docExecutionCtx.updatedLastRunContext[shard].toString().toLong()