Update MonitorRunner.kt

annie3431 · Mar 18, 2022 · 7892da0 · 7892da0
1 parent d20be8c
commit 7892da0
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/alerting/src/main/kotlin/org/opensearch/alerting/MonitorRunner.kt b/alerting/src/main/kotlin/org/opensearch/alerting/MonitorRunner.kt
@@ -830,14 +830,14 @@ object MonitorRunner : JobRunner, CoroutineScope, AbstractLifecycleComponent() {
             triggerName = trigger.name
         )
 
-        val findingStr = finding.toXContent(XContentBuilder.builder(XContentType.JSON.xContent()), ToXContent.EMPTY_PARAMS).string()
+        val findingStr = finding.toXContent(XContentFactory.jsonBuilder(), ToXContent.MapParams(mapOf("with_type" to "true")))
         // change this to debug.
         logger.info("Findings: $findingStr")
 
         // todo: below is all hardcoded, temp code and added only to test. replace this with proper Findings index lifecycle management.
         val indexRequest = IndexRequest(".opensearch-alerting-findings")
             .setRefreshPolicy(WriteRequest.RefreshPolicy.IMMEDIATE)
-            .source(finding.toXContent(XContentFactory.jsonBuilder(), ToXContent.MapParams(mapOf("with_type" to "true"))))
+            .source(findingStr, XContentType.JSON)
 
         client.index(indexRequest).actionGet()
         return finding.id