Index: org.wso2.carbon.ntask.core/4.2.0/src/main/java/org/wso2/carbon/ntask/core/impl/clustered/ClusterGroupCommunicator.java
IDEA additional info:
Subsystem: com.intellij.openapi.diff.impl.patch.CharsetEP
<+>UTF-8
===================================================================
--- org.wso2.carbon.ntask.core/4.2.0/src/main/java/org/wso2/carbon/ntask/core/impl/clustered/ClusterGroupCommunicator.java	(revision 186381)
+++ org.wso2.carbon.ntask.core/4.2.0/src/main/java/org/wso2/carbon/ntask/core/impl/clustered/ClusterGroupCommunicator.java	(revision )
@@ -166,9 +166,11 @@
 
     @Override
     public void memberAdded(MembershipEvent event) {
+        if (hazelcast.getLifecycleService().isRunning()) {
-        Member member = event.getMember();
-        this.membersMap.put(this.getIdFromMember(member), member);
-    }
+            Member member = event.getMember();
+            this.membersMap.put(this.getIdFromMember(member), member);
+        }
+    }
 
     private void scheduleAllMissingTasks() throws TaskException {
         for (String taskType : this.getTaskService().getRegisteredTaskTypes()) {
@@ -198,18 +200,20 @@
 
     @Override
     public void memberRemoved(MembershipEvent event) {
+        if (hazelcast.getLifecycleService().isRunning()) {
-        String id = this.getIdFromMember(event.getMember());
-        this.membersMap.remove(id);
-        this.membersQueue.remove(id);
-        if (this.isLeader()) {
-            try {
-                if (this.isLeader()) {
-                    log.info("Task member departed [" + event.getMember().toString()
-                            + "], rescheduling missing tasks...");
-                    this.scheduleAllMissingTasks();
-                }
-            } catch (TaskException e) {
-                log.error("Error in scheduling missing tasks: " + e.getMessage(), e);
+            String id = this.getIdFromMember(event.getMember());
+            this.membersMap.remove(id);
+            this.membersQueue.remove(id);
+            if (this.isLeader()) {
+                try {
+                    if (this.isLeader()) {
+                        log.info("Task member departed [" + event.getMember().toString()
+                                + "], rescheduling missing tasks...");
+                        this.scheduleAllMissingTasks();
+                    }
+                } catch (TaskException e) {
+                    log.error("Error in scheduling missing tasks: " + e.getMessage(), e);
+                }
             }
         }
     }