You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@helix.apache.org by jx...@apache.org on 2024/08/28 16:35:41 UTC
(helix) branch master updated: Move creating live instance after carryover current state (#2889)
This is an automated email from the ASF dual-hosted git repository.
jxue pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/helix.git
The following commit(s) were added to refs/heads/master by this push:
new f8a30cd57 Move creating live instance after carryover current state (#2889)
f8a30cd57 is described below
commit f8a30cd57c59ce5790346886e522638e019f06ad
Author: frankmu <mu...@gmail.com>
AuthorDate: Wed Aug 28 09:35:35 2024 -0700
Move creating live instance after carryover current state (#2889)
Move creating live instance after carryover current state
---
.../src/main/java/org/apache/helix/manager/zk/ParticipantManager.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
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 5099ee6ac..2044dbcd7 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 class ParticipantManager {
// 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();
/**