From 4e1726d12d155c5d64266b0103828f20cd81ec3a Mon Sep 17 00:00:00 2001 From: Henning Baldersheim Date: Wed, 13 Mar 2024 11:22:58 +0100 Subject: No limitation for search clusters any more. --- .../main/java/com/yahoo/prelude/cluster/ClusterSearcher.java | 12 +++++------- 1 file 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 a8605ab1597..0d9935af43d 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 @@ -136,13 +136,13 @@ public class ClusterSearcher extends Searcher { SummaryParameters docSumParams, DocumentdbInfoConfig documentdbInfoConfig, SchemaInfo schemaInfo, - ComponentRegistry dispatchers) { + ComponentRegistry dispatchers) + { ClusterParams clusterParams = makeClusterParams(searchclusterIndex); ComponentId dispatcherComponentId = new ComponentId("dispatcher." + searchClusterName); Dispatcher dispatcher = dispatchers.getComponent(dispatcherComponentId); if (dispatcher == null) - throw new IllegalArgumentException("Configuration error: No dispatcher " + dispatcherComponentId + - " is configured"); + throw new IllegalArgumentException("Configuration error: No dispatcher " + dispatcherComponentId + " is configured"); return new IndexedBackend(serverId, dispatcher, docSumParams, clusterParams, documentdbInfoConfig, schemaInfo); } @@ -152,10 +152,8 @@ public class ClusterSearcher extends Searcher { SummaryParameters docSumParams, DocumentdbInfoConfig documentdbInfoConfig, SchemaInfo schemaInfo, - VespaDocumentAccess access) { - if (searchClusterConfig.searchdef().size() != 1) - throw new IllegalArgumentException("Streaming search clusters can only contain a single schema but got " + - searchClusterConfig.searchdef()); + VespaDocumentAccess access) + { ClusterParams clusterParams = makeClusterParams(searchclusterIndex); StreamingBackend searcher = new StreamingBackend(access); searcher.setSearchClusterName(searchClusterConfig.rankprofiles_configid()); -- cgit v1.2.3