File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
modules/streams/src/main/java/org/elasticsearch/rest/streams/logs Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change 2828@ ServerlessScope (Scope .PUBLIC )
2929public class RestStreamsStatusAction extends BaseRestHandler {
3030
31- public static final Set <String > SUPPORTED_PARAMS = Collections .singleton (RestUtils .REST_TIMEOUT_PARAM );
31+ public static final Set <String > SUPPORTED_PARAMS = Collections .singleton (RestUtils .REST_MASTER_TIMEOUT_PARAM );
3232
3333 @ Override
3434 public String getName () {
@@ -42,7 +42,7 @@ public List<RestHandler.Route> routes() {
4242
4343 @ Override
4444 protected BaseRestHandler .RestChannelConsumer prepareRequest (RestRequest request , NodeClient client ) {
45- StreamsStatusAction .Request statusRequest = new StreamsStatusAction .Request (RestUtils .getAckTimeout (request ));
45+ StreamsStatusAction .Request statusRequest = new StreamsStatusAction .Request (RestUtils .getMasterNodeTimeout (request ));
4646 return restChannel -> new RestCancellableNodeClient (client , request .getHttpChannel ()).execute (
4747 StreamsStatusAction .INSTANCE ,
4848 statusRequest ,
You can’t perform that action at this time.
0 commit comments