cleaning member list on cluster removed event
Project: http://git-wip-us.apache.org/repos/asf/stratos/repo Commit: http://git-wip-us.apache.org/repos/asf/stratos/commit/c04d2558 Tree: http://git-wip-us.apache.org/repos/asf/stratos/tree/c04d2558 Diff: http://git-wip-us.apache.org/repos/asf/stratos/diff/c04d2558 Branch: refs/heads/master Commit: c04d25580f89bc4501dc445445bd5d16d301f931 Parents: bbdc7cf Author: R-Rajkumar <[email protected]> Authored: Sat Oct 11 19:30:20 2014 +0530 Committer: R-Rajkumar <[email protected]> Committed: Sat Oct 11 19:30:20 2014 +0530 ---------------------------------------------------------------------- .../stratos/autoscaler/monitor/KubernetesClusterMonitor.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/stratos/blob/c04d2558/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/monitor/KubernetesClusterMonitor.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/monitor/KubernetesClusterMonitor.java b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/monitor/KubernetesClusterMonitor.java index 9375a8e..cf5243b 100644 --- a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/monitor/KubernetesClusterMonitor.java +++ b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/monitor/KubernetesClusterMonitor.java @@ -428,7 +428,10 @@ public abstract class KubernetesClusterMonitor extends AbstractClusterMonitor { @Override public void handleClusterRemovedEvent( ClusterRemovedEvent clusterRemovedEvent) { - + getKubernetesClusterCtxt().getPendingMembers().clear(); + getKubernetesClusterCtxt().getActiveMembers().clear(); + getKubernetesClusterCtxt().getTerminationPendingMembers().clear(); + getKubernetesClusterCtxt().getObsoletedMembers().clear(); } public KubernetesClusterContext getKubernetesClusterCtxt() {
