From 07d9efe17963c7506484ad3892a44a5ef7e56d1e Mon Sep 17 00:00:00 2001 From: AWSHurneyt Date: Mon, 5 Feb 2024 03:27:53 -0800 Subject: [PATCH] Troubleshooting. Signed-off-by: AWSHurneyt --- .../src/main/kotlin/org/opensearch/alerting/InputService.kt | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/alerting/src/main/kotlin/org/opensearch/alerting/InputService.kt b/alerting/src/main/kotlin/org/opensearch/alerting/InputService.kt index ac5b475b3..2829bc26a 100644 --- a/alerting/src/main/kotlin/org/opensearch/alerting/InputService.kt +++ b/alerting/src/main/kotlin/org/opensearch/alerting/InputService.kt @@ -129,8 +129,8 @@ class InputService( logger.info("ClusterMetricsInput remoteMonitoringEnabled: $remoteMonitoringEnabled") if (remoteMonitoringEnabled && input.clusters.isNotEmpty()) { - val responseMap = mutableMapOf>() client.threadPool().threadContext.stashContext().use { + val responseMap = mutableMapOf>() scope.launch { val deferredResults = input.clusters.map { cluster -> async {