提交 9c850ffc 编写于 作者: O obdev 提交者: wangzelin.wzl

[CP] do not check scheduler callback if leader switch happen

上级 d2970467
...@@ -212,7 +212,11 @@ void ObPartTransCtx::destroy() ...@@ -212,7 +212,11 @@ void ObPartTransCtx::destroy()
// Defensive Check 3 : missing to callback scheduler // Defensive Check 3 : missing to callback scheduler
if (!is_follower_() && need_callback_scheduler_()) { if (!is_follower_() && need_callback_scheduler_()) {
int ret = OB_TRANS_UNKNOWN; int ret = OB_TRANS_UNKNOWN;
TRANS_LOG(ERROR, "missing callback scheduler, callback with TRANS_UNKNOWN", K(ret), KPC(this)); if (0 == start_working_log_ts_) {
TRANS_LOG(ERROR, "missing callback scheduler, callback with TRANS_UNKNOWN", K(ret), KPC(this));
} else {
TRANS_LOG(WARN, "missing callback scheduler maybe, callback with TRANS_UNKNOWN", K(ret), KPC(this));
}
// NOTE: callback scheduler may introduce deadlock, need take care // NOTE: callback scheduler may introduce deadlock, need take care
trans_service_->handle_tx_commit_result(trans_id_, OB_TRANS_UNKNOWN, -1); trans_service_->handle_tx_commit_result(trans_id_, OB_TRANS_UNKNOWN, -1);
FORCE_PRINT_TRACE(tlog_, "[missing callback scheduler] "); FORCE_PRINT_TRACE(tlog_, "[missing callback scheduler] ");
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册