aboutsummaryrefslogtreecommitdiffstats
path: root/controller-server/src/main
diff options
context:
space:
mode:
authorMartin Polden <mpolden@mpolden.no>2021-12-03 11:31:07 +0100
committerMartin Polden <mpolden@mpolden.no>2021-12-03 11:31:07 +0100
commit6bdde0ca417ff739a520169819c9d89344519c5c (patch)
tree99d1656ad4a8a276299dc3d83c0758baa85d551c /controller-server/src/main
parent127b11b8b0bb649d8c9f5d9452c714d8248d5e0f (diff)
Send distinct upstream names
Diffstat (limited to 'controller-server/src/main')
-rw-r--r--controller-server/src/main/java/com/yahoo/vespa/hosted/controller/routing/context/DeploymentRoutingContext.java6
1 files changed, 5 insertions, 1 deletions
diff --git a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/routing/context/DeploymentRoutingContext.java b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/routing/context/DeploymentRoutingContext.java
index e784666f22a..3124d836e54 100644
--- a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/routing/context/DeploymentRoutingContext.java
+++ b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/routing/context/DeploymentRoutingContext.java
@@ -20,6 +20,7 @@ import java.util.List;
import java.util.Objects;
import java.util.Optional;
import java.util.Set;
+import java.util.stream.Collectors;
/**
* A deployment routing context, which extends {@link RoutingContext} to support routing configuration of a deployment.
@@ -125,7 +126,10 @@ public abstract class DeploymentRoutingContext implements RoutingContext {
List<String> upstreamNames = controller.readEndpointsOf(deployment)
.scope(Endpoint.Scope.zone)
.shared()
- .mapToList(endpoint -> endpoint.upstreamName(deployment));
+ .asList().stream()
+ .map(endpoint -> endpoint.upstreamName(deployment))
+ .distinct()
+ .collect(Collectors.toList());
if (upstreamNames.isEmpty()) {
throw new IllegalArgumentException("No upstream names found for " + deployment);
}