Troubleshooting user injection.

Signed-off-by: AWSHurneyt <hurneyt@amazon.com>
AWSHurneyt · Jan 26, 2024 · f8aeade · f8aeade
1 parent 64b0600
commit f8aeade
Showing 1 changed file with 1 addition and 6 deletions.
diff --git a/...ting/src/main/kotlin/org/opensearch/alerting/transport/TransportGetRemoteIndexesAction.kt b/...ting/src/main/kotlin/org/opensearch/alerting/transport/TransportGetRemoteIndexesAction.kt
@@ -85,13 +85,8 @@ class TransportGetRemoteIndexesAction @Inject constructor(
             .getTransient<String>(ConfigConstants.OPENSEARCH_SECURITY_USER_INFO_THREAD_CONTEXT)
         log.info("hurneyt TransportGetRemoteIndexesAction::userStr = {}", userStr)
 
-        val userStr2 = client.threadPool().threadContext
-            .getTransient<String>(ConfigConstants.INJECTED_USER)
-        log.info("hurneyt TransportGetRemoteIndexesAction::userStr2 = {}", userStr2)
-
         client.threadPool().threadContext.stashContext().use {
-            if (userStr2.isNotEmpty())
-                client.threadPool().threadContext.putTransient(ConfigConstants.INJECTED_USER, userStr2)
+            if (userStr.isNotEmpty()) client.threadPool().threadContext.putTransient(ConfigConstants.INJECTED_USER, userStr)
 
             scope.launch {
                 val clusterIndexesList = mutableListOf<ClusterIndexes>()