From c2e24f2a3728c082c199e4e96aff9cefc35ae444 Mon Sep 17 00:00:00 2001 From: Andrey Ershov Date: Thu, 23 May 2019 16:26:45 -0400 Subject: [PATCH] Run on GENERIC thread pool --- .../cluster/snapshots/get/TransportGetSnapshotsAction.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/server/src/main/java/org/elasticsearch/action/admin/cluster/snapshots/get/TransportGetSnapshotsAction.java b/server/src/main/java/org/elasticsearch/action/admin/cluster/snapshots/get/TransportGetSnapshotsAction.java index 1efd0497dd845..4cef566ac2df1 100644 --- a/server/src/main/java/org/elasticsearch/action/admin/cluster/snapshots/get/TransportGetSnapshotsAction.java +++ b/server/src/main/java/org/elasticsearch/action/admin/cluster/snapshots/get/TransportGetSnapshotsAction.java @@ -108,9 +108,9 @@ private void getMultipleReposSnapshotInfo(List repos, String boolean verbose, ActionListener listener) { List>> futures = new ArrayList<>(repos.size()); - // run concurrently for all repos on SNAPSHOT thread pool + // run concurrently for all repos on GENERIC thread pool for (final RepositoryMetaData repo : repos) { - futures.add(threadPool.executor(ThreadPool.Names.SNAPSHOT).submit( + futures.add(threadPool.executor(ThreadPool.Names.GENERIC).submit( () -> getSingleRepoSnapshotInfo(repo.name(), snapshots, ignoreUnavailable, verbose))); } assert repos.size() == futures.size();