Repository: stratos Updated Branches: refs/heads/stratos-4.1.x 4df694d08 -> 848067c44
Making load balancer ips distinct for kubernetes nodes Project: http://git-wip-us.apache.org/repos/asf/stratos/repo Commit: http://git-wip-us.apache.org/repos/asf/stratos/commit/848067c4 Tree: http://git-wip-us.apache.org/repos/asf/stratos/tree/848067c4 Diff: http://git-wip-us.apache.org/repos/asf/stratos/diff/848067c4 Branch: refs/heads/stratos-4.1.x Commit: 848067c44ea88f1f19f1e23ef32fc55753e33521 Parents: 4df694d Author: Imesh Gunaratne <[email protected]> Authored: Wed Oct 14 17:41:14 2015 +0530 Committer: Imesh Gunaratne <[email protected]> Committed: Wed Oct 14 17:41:14 2015 +0530 ---------------------------------------------------------------------- .../cloud/controller/messaging/topology/TopologyBuilder.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/stratos/blob/848067c4/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/messaging/topology/TopologyBuilder.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/messaging/topology/TopologyBuilder.java b/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/messaging/topology/TopologyBuilder.java index aa06ba9..30a0167 100644 --- a/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/messaging/topology/TopologyBuilder.java +++ b/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/messaging/topology/TopologyBuilder.java @@ -866,7 +866,7 @@ public class TopologyBuilder { if ((kubernetesServices != null) && (kubernetesServices.size() > 0)) { try { // Generate access URLs for kubernetes services - List<String> nodePublicIps = new ArrayList<>(); + Set<String> nodePublicIps = new HashSet<>(); for (KubernetesService kubernetesService : kubernetesServices) { // Add node ips as load balancer ips nodePublicIps.addAll(Arrays.asList(kubernetesService.getPublicIPs())); @@ -891,7 +891,9 @@ public class TopologyBuilder { } if(cluster.getLoadBalancerIps().size() == 0) { // Load balancer ips not given, use node public ips as load balancer ips - clusterInstanceActivatedEvent.setLoadBalancerIps(nodePublicIps); + List<String> nodePublicIpsList = new ArrayList<>(); + nodePublicIpsList.addAll(nodePublicIps); + clusterInstanceActivatedEvent.setLoadBalancerIps(nodePublicIpsList); } log.info(String.format("Access URLs generated for kubernetes services: [application] %s " + "[cluster] %s [access-urls] %s",
