diff --git a/alerting/src/main/kotlin/org/opensearch/alerting/transport/TransportGetFindingsSearchAction.kt b/alerting/src/main/kotlin/org/opensearch/alerting/transport/TransportGetFindingsSearchAction.kt index bb07ee6f5..3766568ec 100644 --- a/alerting/src/main/kotlin/org/opensearch/alerting/transport/TransportGetFindingsSearchAction.kt +++ b/alerting/src/main/kotlin/org/opensearch/alerting/transport/TransportGetFindingsSearchAction.kt @@ -129,7 +129,6 @@ class TransportGetFindingsSearchAction @Inject constructor( object : ActionListener { override fun onResponse(response: SearchResponse) { val totalFindingCount = response.hits.totalHits?.value?.toInt() - val findings = mutableListOf() val findingsWithDocs = mutableListOf() for (hit in response.hits) { val id = hit.id @@ -138,11 +137,9 @@ class TransportGetFindingsSearchAction @Inject constructor( XContentParserUtils.ensureExpectedToken(XContentParser.Token.START_OBJECT, xcp.nextToken(), xcp) val finding = Finding.parse(xcp, id) val doc_ids = finding.relatedDocId.split(",").toTypedArray() - val sourceIndex = finding.index val docs = mutableListOf() - findings.add(finding) for (doc_id in doc_ids) { - val document = searchDocument(doc_id, sourceIndex, docs, actionListener) + val document = searchDocument(doc_id, finding.index, docs, actionListener) // TODO: remove debug log log.info("document: $document") } @@ -166,7 +163,7 @@ class TransportGetFindingsSearchAction @Inject constructor( sourceIndex: String, docs: List, actionListener: ActionListener - ): FindingDocument? { + ) { val getRequest = GetRequest(sourceIndex, documentId) var findingDocument: FindingDocument? = null client.threadPool().threadContext.stashContext().use { @@ -203,7 +200,6 @@ class TransportGetFindingsSearchAction @Inject constructor( } } ) - return findingDocument } } }