diff options
author | Martin Polden <mpolden@mpolden.no> | 2021-12-03 11:31:07 +0100 |
---|---|---|
committer | Martin Polden <mpolden@mpolden.no> | 2021-12-03 11:31:07 +0100 |
commit | 6bdde0ca417ff739a520169819c9d89344519c5c (patch) | |
tree | 99d1656ad4a8a276299dc3d83c0758baa85d551c /controller-server/src/main | |
parent | 127b11b8b0bb649d8c9f5d9452c714d8248d5e0f (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.java | 6 |
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); } |