Need to wait a bit before executing the label query.
Project: http://git-wip-us.apache.org/repos/asf/stratos/repo Commit: http://git-wip-us.apache.org/repos/asf/stratos/commit/87b0ba14 Tree: http://git-wip-us.apache.org/repos/asf/stratos/tree/87b0ba14 Diff: http://git-wip-us.apache.org/repos/asf/stratos/diff/87b0ba14 Branch: refs/heads/container-autoscaling Commit: 87b0ba14aeb941596a21f9dd8dad524247e1ac4a Parents: d5e497f Author: Nirmal Fernando <[email protected]> Authored: Wed Oct 8 19:05:04 2014 +0530 Committer: Nirmal Fernando <[email protected]> Committed: Wed Oct 8 22:21:30 2014 +0530 ---------------------------------------------------------------------- .../controller/impl/CloudControllerServiceImpl.java | 11 ++++++++++- 1 file changed, 10 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/stratos/blob/87b0ba14/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/impl/CloudControllerServiceImpl.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/impl/CloudControllerServiceImpl.java b/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/impl/CloudControllerServiceImpl.java index a413882..4042140 100644 --- a/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/impl/CloudControllerServiceImpl.java +++ b/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/impl/CloudControllerServiceImpl.java @@ -1413,11 +1413,20 @@ public class CloudControllerServiceImpl implements CloudControllerService { + controller + " via Kubernetes layer."); } + // needs to wait few seconds before running label queries + Thread.sleep(3000); + // create a label query Label l = new Label(); l.setName(clusterId); // execute the label query Pod[] newlyCreatedPods = kubApi.getSelectedPods(new Label[]{l}); + + if (log.isDebugEnabled()) { + + log.debug(String.format("Pods created : %s for cluster : %s",newlyCreatedPods.length, clusterId)); + } + List<MemberContext> memberContexts = new ArrayList<MemberContext>(); PodToMemberContext podToMemberContextFunc = new PodToMemberContext(); @@ -1447,7 +1456,7 @@ public class CloudControllerServiceImpl implements CloudControllerService { // persist in registry persist(); - log.info("Kubernetes entities are successfully starting up. "+containerClusterContext.toString()); + log.info("Kubernetes entities are successfully starting up. "+memberContexts); return memberContexts.toArray(new MemberContext[0]);
