Remove redundent logic after imp for coordination

Fixes: #3693
wso2 · Oct 25, 2024 · 781124f · 781124f
1 parent 1338d60
commit 781124f
Showing 1 changed file with 0 additions and 15 deletions.
diff --git a/...re/src/main/java/org/wso2/micro/integrator/ntask/coordination/task/TaskEventListener.java b/...re/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) {