You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@stratos.apache.org by ni...@apache.org on 2014/10/08 18:53:21 UTC
[27/27] git commit: Need to wait a bit before executing the label
query.
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 <ni...@gmail.com>
Authored: Wed Oct 8 19:05:04 2014 +0530
Committer: Nirmal Fernando <ni...@gmail.com>
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]);