hcq/oceanbase
hcq/oceanbase
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

cancel sensing store restart though heartbeat

Browse Source
This commit is contained in:
obdev 2024-03-08 02:46:05 +00:00 committed by ob-robot
parent d660015ed5
commit 64b2733ba3
1 changed files with 2 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/observer/table_load/ob_table_load_coordinator.cpp
View File

@ -853,18 +853,8 @@ int ObTableLoadCoordinator::heart_beat()
ret = OB_NOT_INIT;
LOG_WARN("ObTableLoadCoordinator not init", KR(ret), KP(this));
} else {
LOG_DEBUG("coordinator heart beat");
// 心跳是为了让数据节点感知控制节点存活, 让控制节点感知数据节点是否重启过（返回-4018），忽略其它失败
if (OB_FAIL(heart_beat_peer())) {
if (ret == OB_ENTRY_NOT_EXIST) {
LOG_WARN("store has been restarted", K(ret));
if (OB_FAIL(coordinator_ctx_->set_status_abort())) {
LOG_WARN("fail to set coordinator status abort", KR(ret));
} else {
coordinator_ctx_->set_enable_heart_beat(false);
}
}
}
// 心跳是为了让数据节点感知控制节点存活, 控制节点不依赖心跳感知数据节点状态, 忽略失败
heart_beat_peer();
}
return ret;
}