Merge pull request #3737 from malakaganga/fix_node_resolver

Remove redundant logic after imp for coordination

components/mediation/tasks/org.wso2.micro.integrator.ntask.core/src/main/java/org/wso2/micro/integrator/ntask/coordination/task/TaskEventListener.java

@@ -75,12 +75,6 @@ public void memberAdded(NodeDetail nodeDetail) {
                 LOG.error("Exception occurred while resolving un assigned tasks upon member addition " + nodeDetail
                         .getNodeId(), e);
             }
-        } else if (clusterCoordinator.getThisNodeId().equals(nodeDetail.getNodeId())
-                && isMemberRejoinedAfterUnresponsiveness()) {
-            // This node became unresponsive and rejoined the cluster hence removing all tasks assigned to this node
-            // then start the scheduler again after cleaning the locally running tasks.
-            becameUnresponsive(nodeDetail.getNodeId());
-            reJoined(nodeDetail.getNodeId(), null);
         }
     }
 
@@ -134,15 +128,6 @@ public void becameUnresponsive(String nodeId) {
         }
     }
 
-    /**
-     * Check whether the member has rejoined after being unresponsive.
-     *
-     * @return true if the member has rejoined after being unresponsive, false otherwise
-     */
-    public boolean isMemberRejoinedAfterUnresponsiveness() {
-        return taskManager.getLocallyRunningCoordinatedTasks().size() > 0;
-    }
-
 
     @Override
     public void reJoined(String nodeId, RDBMSMemberEventCallBack callBack) {