Fixed the issue with participant re-enabling when coming back to the cluster after a graceful shutdown
@@ -152,6 +152,7 @@ public class HelixParticipant<T extends AbstractTask> implements Runnable {
if (taskTypeName != null) {
zkHelixAdmin.addInstanceTag(clusterName, participantName, taskTypeName);
}
+ zkHelixAdmin.enableInstance(clusterName, participantName, true);
}
Runtime.getRuntime().addShutdownHook(
