提交 1c41b3c1 编写于 作者: O obdev 提交者: ob-robot

fix ask trans state stops sending requests without collecting all participant information

上级 5ef499a5
......@@ -404,6 +404,10 @@ int ObAllTenantInfoProxy::update_tenant_recovery_status(
ret = OB_ERR_UNEXPECTED;
LOG_WARN("expect updating one row", KR(ret), K(affected_rows), K(sql));
}
LOG_TRACE("update_tenant_recovery_status", KR(ret), K(tenant_id), K(affected_rows), K(status),
K(sql), K(old_tenant_info), K(new_sync_scn), K(new_replay_scn), K(new_scn),
K(sync_scn), K(replay_scn), K(readable_scn));
}
if (trans.is_started()) {
int tmp_ret = OB_SUCCESS;
......
......@@ -6646,6 +6646,7 @@ int ObPartTransCtx::check_for_standby(const SCN &snapshot,
ret = OB_SUCCESS;
}
}
TRANS_LOG(INFO, "check for standby for unknown", K(ret), K(snapshot), K(can_read), K(trans_version), K(is_determined_state), K(tmp_state_info), K(readable_scn));
}
break;
}
......@@ -6793,7 +6794,7 @@ void ObPartTransCtx::handle_trans_ask_state_(const SCN &snapshot)
{
if (snapshot > lastest_snapshot_) {
build_and_post_collect_state_msg_(snapshot);
} else if (snapshot <= lastest_snapshot_ && standby_part_collected_.num_members() != state_info_array_.count()-1) {
} else if (snapshot <= lastest_snapshot_ && standby_part_collected_.num_members() != state_info_array_.count()) {
if (refresh_state_info_interval_.reach()) {
build_and_post_collect_state_msg_(snapshot);
}
......
......@@ -3098,7 +3098,6 @@ int ObTransService::check_and_fill_state_info(const ObTransID &tx_id, ObStateInf
int tx_state = ObTxData::RUNNING;
SCN version;
if (OB_FAIL(get_tx_state_from_tx_table_(state_info.ls_id_, tx_id, tx_state, version))) {
TRANS_LOG(INFO, "get tx state from tx table fail", K(ret), K(state_info.ls_id_), K(tx_id));
if (OB_TRANS_CTX_NOT_EXIST == ret) {
ObLSService *ls_svr = MTL(ObLSService *);
ObLSHandle handle;
......@@ -3118,6 +3117,7 @@ int ObTransService::check_and_fill_state_info(const ObTransID &tx_id, ObStateInf
} else {
ret = OB_TRANS_CTX_NOT_EXIST;
}
TRANS_LOG(INFO, "get tx state from tx table fail", K(ret), K(state_info), K(tx_id), K(version));
}
} else {
switch (tx_state) {
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册