Update TransportGetFindingsSearchAction.kt

annie3431 · Mar 23, 2022 · 9182aa3 · 9182aa3
1 parent babd908
commit 9182aa3
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...ing/src/main/kotlin/org/opensearch/alerting/transport/TransportGetFindingsSearchAction.kt b/...ing/src/main/kotlin/org/opensearch/alerting/transport/TransportGetFindingsSearchAction.kt
@@ -160,11 +160,11 @@ class TransportGetFindingsSearchAction @Inject constructor(
                         log.info("Parsing new finding with id: $id")
                         val finding = Finding.parse(xcp, id)
                         // TODO: Search the document with doc_id
-                        val doc_ids = finding.relatedDocId
+                        val doc_ids = finding.relatedDocId.split(",").toTypedArray()
                         val sourceIndex = finding.index
-                        log.info("doc_ids: $doc_ids")
                         findings.add(finding)
                         for (doc_id in doc_ids) {
+                        log.info("doc_id: $doc_id)
                             // Search document in index
                             searchDocument(doc_id, sourceIndex, actionListener)
                         }