Skip to content

Commit 7313e5f

Browse files
committed
Get from transportService if null
Signed-off-by: Craig Perkins <[email protected]>
1 parent 39a7a0b commit 7313e5f

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

server/src/main/java/org/opensearch/action/support/replication/TransportReplicationAction.java

+2
Original file line numberDiff line numberDiff line change
@@ -243,6 +243,8 @@ protected TransportReplicationAction(
243243
this.threadPool = threadPool;
244244
if (threadPool != null) {
245245
this.tcWrapper = InternalThreadContextWrapper.from(threadPool.getThreadContext());
246+
} else {
247+
this.tcWrapper = InternalThreadContextWrapper.from(transportSeervice.threadPool.getThreadContext());
246248
}
247249
this.transportService = transportService;
248250
this.clusterService = clusterService;

0 commit comments

Comments
 (0)