Skip to content

Commit

Permalink
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
May as well finish up on the ccr threadpool too
Browse files Browse the repository at this point in the history
DaveCTurner committed Dec 22, 2022
1 parent 1144329 commit a194c11
Showing 2 changed files with 4 additions and 4 deletions.
Original file line number Diff line number Diff line change
@@ -14,7 +14,7 @@
import org.elasticsearch.rest.BaseRestHandler;
import org.elasticsearch.rest.RestRequest;
import org.elasticsearch.rest.action.RestChunkedToXContentListener;
import org.elasticsearch.threadpool.ThreadPool;
import org.elasticsearch.xpack.ccr.Ccr;
import org.elasticsearch.xpack.core.ccr.action.CcrStatsAction;

import java.util.List;
@@ -44,7 +44,7 @@ protected RestChannelConsumer prepareRequest(final RestRequest restRequest, fina
new ThreadedActionListener<>(
logger,
client.threadPool(),
ThreadPool.Names.MANAGEMENT,
Ccr.CCR_THREAD_POOL_NAME,
new RestChunkedToXContentListener<>(channel),
false
)
Original file line number Diff line number Diff line change
@@ -15,7 +15,7 @@
import org.elasticsearch.rest.BaseRestHandler;
import org.elasticsearch.rest.RestRequest;
import org.elasticsearch.rest.action.RestChunkedToXContentListener;
import org.elasticsearch.threadpool.ThreadPool;
import org.elasticsearch.xpack.ccr.Ccr;
import org.elasticsearch.xpack.core.ccr.action.FollowStatsAction;

import java.util.List;
@@ -46,7 +46,7 @@ protected RestChannelConsumer prepareRequest(final RestRequest restRequest, fina
new ThreadedActionListener<>(
logger,
client.threadPool(),
ThreadPool.Names.MANAGEMENT,
Ccr.CCR_THREAD_POOL_NAME,
new RestChunkedToXContentListener<>(channel),
false
)

0 comments on commit a194c11

Please sign in to comment.