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/11 06:12:55 UTC
[09/50] [abbrv] 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/b14a5c07
Tree: http://git-wip-us.apache.org/repos/asf/stratos/tree/b14a5c07
Diff: http://git-wip-us.apache.org/repos/asf/stratos/diff/b14a5c07
Branch: refs/heads/master
Commit: b14a5c075a7d2eda8dc2fbf4fda7570b63da9958
Parents: 08cd01b
Author: Nirmal Fernando <ni...@gmail.com>
Authored: Wed Oct 8 19:05:04 2014 +0530
Committer: Nirmal Fernando <ni...@gmail.com>
Committed: Sat Oct 11 09:30:55 2014 +0530
----------------------------------------------------------------------
.../controller/impl/CloudControllerServiceImpl.java | 11 ++++++++++-
1 file changed, 10 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/stratos/blob/b14a5c07/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]);