From 7b21688e4f432f9e09498869a19efd9831ab544a Mon Sep 17 00:00:00 2001 From: Kaushal Kumar Date: Thu, 11 Jul 2024 14:55:48 -0700 Subject: [PATCH] move query group thread context propagator out of ThreadContext Signed-off-by: Kaushal Kumar --- .../org/opensearch/common/util/concurrent/ThreadContext.java | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/server/src/main/java/org/opensearch/common/util/concurrent/ThreadContext.java b/server/src/main/java/org/opensearch/common/util/concurrent/ThreadContext.java index 3925c84ac7261..906a27e9f398c 100644 --- a/server/src/main/java/org/opensearch/common/util/concurrent/ThreadContext.java +++ b/server/src/main/java/org/opensearch/common/util/concurrent/ThreadContext.java @@ -47,7 +47,6 @@ import org.opensearch.http.HttpTransportSettings; import org.opensearch.tasks.Task; import org.opensearch.tasks.TaskThreadContextStatePropagator; -import org.opensearch.wlm.QueryGroupThreadContextStatePropagator; import java.io.IOException; import java.nio.charset.StandardCharsets; @@ -129,9 +128,7 @@ public ThreadContext(Settings settings) { this.threadLocal = ThreadLocal.withInitial(() -> DEFAULT_CONTEXT); this.maxWarningHeaderCount = SETTING_HTTP_MAX_WARNING_HEADER_COUNT.get(settings); this.maxWarningHeaderSize = SETTING_HTTP_MAX_WARNING_HEADER_SIZE.get(settings).getBytes(); - this.propagators = new CopyOnWriteArrayList<>( - List.of(new TaskThreadContextStatePropagator(), new QueryGroupThreadContextStatePropagator()) - ); + this.propagators = new CopyOnWriteArrayList<>(List.of(new TaskThreadContextStatePropagator())); } public void registerThreadContextStatePropagator(final ThreadContextStatePropagator propagator) {