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

[MDS] fix ERROR log in compat case

Browse Source
This commit is contained in:
fengdeyiji
2023-06-28 10:18:03 +00:00
committed by ob-robot
parent 58caa336f2
commit 68bf34f035
1 changed files with 11 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
src/storage/tx/ob_trans_define.cpp
View File

@ -1087,10 +1087,17 @@ void ObTxExecInfo::mrege_buffer_ctx_array_to_multi_data_source() const
ObTxBufferCtxArray &mds_buffer_ctx_array = const_cast<ObTxBufferCtxArray &>(mds_buffer_ctx_array_); ObTxBufferCtxArray &mds_buffer_ctx_array = const_cast<ObTxBufferCtxArray &>(mds_buffer_ctx_array_);
TRANS_LOG_RET(INFO, OB_SUCCESS, "merge deserialized buffer ctx to multi_data_source", K(mds_buffer_ctx_array), K(multi_data_source)); TRANS_LOG_RET(INFO, OB_SUCCESS, "merge deserialized buffer ctx to multi_data_source", K(mds_buffer_ctx_array), K(multi_data_source));
if (mds_buffer_ctx_array.count() != multi_data_source.count()) { if (mds_buffer_ctx_array.count() != multi_data_source.count()) {
TRANS_LOG_RET(ERROR, OB_ERR_UNEXPECTED, if (mds_buffer_ctx_array.count() == 0) {// 4.1 -> 4.2 compat case
"mds buffer ctx array size not equal to multi data source array size" TRANS_LOG_RET(WARN, OB_ERR_UNEXPECTED,
", destroy deserialized mds_buffer_ctx_array directly", "mds buffer ctx array size not equal to multi data source array size"
K(multi_data_source), K(mds_buffer_ctx_array), K(*this)); ", destroy deserialized mds_buffer_ctx_array directly",
K(multi_data_source), K(mds_buffer_ctx_array), K(*this));
} else {
TRANS_LOG_RET(ERROR, OB_ERR_UNEXPECTED,
"mds buffer ctx array size not equal to multi data source array size"
", destroy deserialized mds_buffer_ctx_array directly",
K(multi_data_source), K(mds_buffer_ctx_array), K(*this));
}
for (int64_t idx = 0; idx < mds_buffer_ctx_array.count(); ++idx) { for (int64_t idx = 0; idx < mds_buffer_ctx_array.count(); ++idx) {
mds_buffer_ctx_array[idx].destroy_ctx(); mds_buffer_ctx_array[idx].destroy_ctx();
} }