use updated index names while process findings

Signed-off-by: Surya Sashank Nistala <[email protected]>
eirsep · Jan 11, 2024 · 4f90cc2 · 4f90cc2
1 parent c683e63
commit 4f90cc2
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/alerting/src/main/kotlin/org/opensearch/alerting/DocumentLevelMonitorRunner.kt b/alerting/src/main/kotlin/org/opensearch/alerting/DocumentLevelMonitorRunner.kt
@@ -160,6 +160,7 @@ object DocumentLevelMonitorRunner : MonitorRunner() {
             val transformedDocs = mutableListOf<Pair<String, TransformedDocDto>>()
             val docsSizeInBytes = AtomicLong(0)
             val concreteIndicesSeenSoFar = mutableListOf<String>()
+            val updatedIndexNames = mutableListOf<String>()
             docLevelMonitorInput.indices.forEach { indexName ->
 
                 var concreteIndices = IndexUtils.resolveAllIndices(
@@ -184,6 +185,7 @@ object DocumentLevelMonitorRunner : MonitorRunner() {
                 }
                 concreteIndicesSeenSoFar.addAll(concreteIndices)
                 val updatedIndexName = indexName.replace("*", "_")
+                updatedIndexNames.add(updatedIndexName)
                 val conflictingFields = monitorCtx.docLevelMonitorQueries!!.getAllConflictingFields(
                     monitorCtx.clusterService!!.state(),
                     concreteIndices
@@ -245,7 +247,7 @@ object DocumentLevelMonitorRunner : MonitorRunner() {
                         docsToQueries,
                         transformedDocs,
                         docsSizeInBytes,
-                        docLevelMonitorInput.indices,
+                        updatedIndexNames,
                         concreteIndicesSeenSoFar
                     )
                 }
@@ -259,7 +261,7 @@ object DocumentLevelMonitorRunner : MonitorRunner() {
                     docsSizeInBytes,
                     monitor,
                     monitorMetadata,
-                    docLevelMonitorInput.indices,
+                    updatedIndexNames,
                     concreteIndicesSeenSoFar,
                     inputRunResults,
                     docsToQueries