diff --git a/helix-core/src/main/java/org/apache/helix/manager/zk/ParticipantManager.java b/helix-core/src/main/java/org/apache/helix/manager/zk/ParticipantManager.java index 5099ee6acf..2044dbcd79 100644 --- a/helix-core/src/main/java/org/apache/helix/manager/zk/ParticipantManager.java +++ b/helix-core/src/main/java/org/apache/helix/manager/zk/ParticipantManager.java @@ -156,11 +156,11 @@ public void handleNewSession() throws Exception { // This will help to prevent controller from sending any message prematurely. // Live instance creation also checks if the expected session is valid or not. Live instance // should not be created by an expired zk session. - createLiveInstance(); if (shouldCarryOver()) { carryOverPreviousCurrentState(_dataAccessor, _instanceName, _sessionId, _manager.getStateMachineEngine(), true); } + createLiveInstance(); removePreviousTaskCurrentStates(); /**