fix ccr

elastic · Jun 14, 2021 · 94f44ed · 94f44ed
1 parent d875e8c
commit 94f44ed
Showing 1 changed file with 11 additions and 10 deletions.
diff --git a/x-pack/plugin/ccr/src/main/java/org/elasticsearch/xpack/ccr/repository/CcrRepository.java b/x-pack/plugin/ccr/src/main/java/org/elasticsearch/xpack/ccr/repository/CcrRepository.java
@@ -185,16 +185,17 @@ public void getSnapshotInfo(GetSnapshotInfoContext context) {
         ArrayList<String> indices = new ArrayList<>(indicesMap.size());
         indicesMap.keysIt().forEachRemaining(indices::add);
 
-        context.onResponse(
-                new SnapshotInfo(
-                        SNAPSHOT_ID,
-                        indices,
-                        new ArrayList<>(metadata.dataStreams().keySet()),
-                        Collections.emptyList(),
-                        response.getState().getNodes().getMaxNodeVersion(),
-                        SnapshotState.SUCCESS
-                )
-        );
+        // fork to the snapshot meta pool because the context expects to run on it and asserts that it does
+        threadPool.executor(ThreadPool.Names.SNAPSHOT_META).execute(() -> context.onResponse(
+            new SnapshotInfo(
+                SNAPSHOT_ID,
+                indices,
+                new ArrayList<>(metadata.dataStreams().keySet()),
+                Collections.emptyList(),
+                response.getState().getNodes().getMaxNodeVersion(),
+                SnapshotState.SUCCESS
+            )
+        ));
     }
 
     @Override