From 5841cd4b73a7c0e7cdf015e59bfb02b5e8e6fb4f Mon Sep 17 00:00:00 2001 From: "ievgen.degtiarenko" Date: Tue, 3 Jun 2025 17:37:44 +0200 Subject: [PATCH] Reduce concurrent clients --- .../java/org/elasticsearch/xpack/esql/plugin/QueryPragmas.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/plugin/QueryPragmas.java b/x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/plugin/QueryPragmas.java index b0a99abf14288..29951070a96cb 100644 --- a/x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/plugin/QueryPragmas.java +++ b/x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/plugin/QueryPragmas.java @@ -32,7 +32,7 @@ */ public final class QueryPragmas implements Writeable { public static final Setting EXCHANGE_BUFFER_SIZE = Setting.intSetting("exchange_buffer_size", 10); - public static final Setting EXCHANGE_CONCURRENT_CLIENTS = Setting.intSetting("exchange_concurrent_clients", 3); + public static final Setting EXCHANGE_CONCURRENT_CLIENTS = Setting.intSetting("exchange_concurrent_clients", 2); public static final Setting ENRICH_MAX_WORKERS = Setting.intSetting("enrich_max_workers", 1); private static final Setting TASK_CONCURRENCY = Setting.intSetting(