Skip to content

Commit

Permalink
Fix AINode status error after ConfigNode Leader restarts #13547
Browse files Browse the repository at this point in the history
Signed-off-by: OneSizeFitQuorum <tanxinyu@apache.org>
  • Loading branch information
OneSizeFitsQuorum committed Sep 20, 2024
1 parent 3f922e7 commit 1940261
Showing 1 changed file with 12 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -19,6 +19,7 @@

package org.apache.iotdb.confignode.manager.load.cache;

import org.apache.iotdb.common.rpc.thrift.TAINodeConfiguration;
import org.apache.iotdb.common.rpc.thrift.TConfigNodeLocation;
import org.apache.iotdb.common.rpc.thrift.TConsensusGroupId;
import org.apache.iotdb.common.rpc.thrift.TConsensusGroupType;
Expand Down Expand Up @@ -98,7 +99,8 @@ public LoadCache() {
public void initHeartbeatCache(IManager configManager) {
initNodeHeartbeatCache(
configManager.getNodeManager().getRegisteredConfigNodes(),
configManager.getNodeManager().getRegisteredDataNodes());
configManager.getNodeManager().getRegisteredDataNodes(),
configManager.getNodeManager().getRegisteredAINodes());
initRegionGroupHeartbeatCache(
configManager.getClusterSchemaManager().getDatabaseNames().stream()
.collect(
Expand All @@ -110,7 +112,8 @@ public void initHeartbeatCache(IManager configManager) {
/** Initialize the nodeCacheMap when the ConfigNode-Leader is switched. */
private void initNodeHeartbeatCache(
List<TConfigNodeLocation> registeredConfigNodes,
List<TDataNodeConfiguration> registeredDataNodes) {
List<TDataNodeConfiguration> registeredDataNodes,
List<TAINodeConfiguration> registeredAINodes) {

final int CURRENT_NODE_ID = ConfigNodeHeartbeatCache.CURRENT_NODE_ID;
nodeCacheMap.clear();
Expand All @@ -136,6 +139,13 @@ private void initNodeHeartbeatCache(
int dataNodeId = dataNodeConfiguration.getLocation().getDataNodeId();
createNodeHeartbeatCache(NodeType.DataNode, dataNodeId);
});

// Init AiNodeHeartbeatCache
registeredAINodes.forEach(
aiNodeConfiguration -> {
int aiNodeId = aiNodeConfiguration.getLocation().getAiNodeId();
createNodeHeartbeatCache(NodeType.AINode, aiNodeId);
});
}

/**
Expand Down

0 comments on commit 1940261

Please sign in to comment.