Get from transportService if null

Signed-off-by: Craig Perkins <[email protected]>
opensearch-project · Jul 26, 2024 · 7313e5f · 7313e5f
1 parent 39a7a0b
commit 7313e5f
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/...r/src/main/java/org/opensearch/action/support/replication/TransportReplicationAction.java b/...r/src/main/java/org/opensearch/action/support/replication/TransportReplicationAction.java
@@ -243,6 +243,8 @@ protected TransportReplicationAction(
         this.threadPool = threadPool;
         if (threadPool != null) {
             this.tcWrapper = InternalThreadContextWrapper.from(threadPool.getThreadContext());
+        } else {
+            this.tcWrapper = InternalThreadContextWrapper.from(transportSeervice.threadPool.getThreadContext());
         }
         this.transportService = transportService;
         this.clusterService = clusterService;