summaryrefslogtreecommitdiffstats
path: root/container-search/src/main/java/com/yahoo/prelude/cluster/ClusterSearcher.java
diff options
context:
space:
mode:
Diffstat (limited to 'container-search/src/main/java/com/yahoo/prelude/cluster/ClusterSearcher.java')
-rw-r--r--container-search/src/main/java/com/yahoo/prelude/cluster/ClusterSearcher.java12
1 files changed, 5 insertions, 7 deletions
diff --git a/container-search/src/main/java/com/yahoo/prelude/cluster/ClusterSearcher.java b/container-search/src/main/java/com/yahoo/prelude/cluster/ClusterSearcher.java
index a18250fbcfe..c29c7d12f9a 100644
--- a/container-search/src/main/java/com/yahoo/prelude/cluster/ClusterSearcher.java
+++ b/container-search/src/main/java/com/yahoo/prelude/cluster/ClusterSearcher.java
@@ -243,14 +243,12 @@ public class ClusterSearcher extends Searcher {
if (restrict.size() != 1) {
throw new IllegalStateException("perSchemaSearch must always be called with 1 schema, got: " + restrict.size());
}
- for (String schema : restrict) {
- Result result = searcher.search(query, execution);
- if (globalPhaseHelper != null) {
- globalPhaseHelper.process(query, result, schema);
- }
- return result;
+ String schema = restrict.iterator().next();
+ Result result = searcher.search(query, execution);
+ if (globalPhaseHelper != null) {
+ globalPhaseHelper.process(query, result, schema);
}
- return null;
+ return result;
}
private static void processResult(Query query, FutureTask<Result> task, Result mergedResult) {