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

fix errno

Browse Source
This commit is contained in:
yangqise7en
2023-07-31 09:18:28 +00:00
committed by ob-robot
parent 971421a5ef
commit 6e1b94044f
3 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/storage/compaction/ob_medium_compaction_info.cpp
View File

@ -127,7 +127,7 @@ int ObParallelMergeInfo::deserialize(
for (int i = 0; OB_SUCC(ret) && i < list_size_; ++i) { for (int i = 0; OB_SUCC(ret) && i < list_size_; ++i) {
if (OB_FAIL(tmp_datum_rowkey.deserialize(buf, data_len, pos))) { if (OB_FAIL(tmp_datum_rowkey.deserialize(buf, data_len, pos))) {
LOG_WARN("failed to decode datum rowkey", K(ret), K(i), K(list_size_), K(data_len), K(pos)); LOG_WARN("failed to decode datum rowkey", K(ret), K(i), K(list_size_), K(data_len), K(pos));
} else if (tmp_datum_rowkey.deep_copy(parallel_datum_rowkey_list_[i] /*dst*/, allocator)) { } else if (OB_FAIL(tmp_datum_rowkey.deep_copy(parallel_datum_rowkey_list_[i] /*dst*/, allocator))) {
LOG_WARN("failed to deep copy datum rowkey", KR(ret), K(i), K(tmp_datum_rowkey)); LOG_WARN("failed to deep copy datum rowkey", KR(ret), K(i), K(tmp_datum_rowkey));
} }
} // end of for } // end of for

1
src/storage/compaction/ob_partition_merger.cpp
View File

@ -1739,6 +1739,7 @@ void ObPartitionMergeDumper::print_error_info(const int err_no,
ret = OB_ERR_UNEXPECTED; ret = OB_ERR_UNEXPECTED;
STORAGE_LOG(WARN, "Unexpected null macro block", K(ret), KPC(macro_desc), KPC(cur_iter)); STORAGE_LOG(WARN, "Unexpected null macro block", K(ret), KPC(macro_desc), KPC(cur_iter));
} else if (OB_ISNULL(curr_row)) { } else if (OB_ISNULL(curr_row)) {
ret = OB_ERR_UNEXPECTED;
STORAGE_LOG(WARN, "merge iter content: ", K(midx), K(cur_iter->get_table()->get_key()), STORAGE_LOG(WARN, "merge iter content: ", K(midx), K(cur_iter->get_table()->get_key()),
KPC(macro_desc)); KPC(macro_desc));
} else { } else {

3
src/storage/tablet/ob_tablet_dumped_medium_info.cpp
View File

@ -342,9 +342,10 @@ int ObTabletDumpedMediumInfo::deserialize(common::ObIAllocator &allocator, const
} }
if (OB_FAIL(ret)) { if (OB_FAIL(ret)) {
for (int64_t i = 0; i < medium_info_list_.count(); ++i) { for (int64_t i = 0; OB_SUCC(ret) && i < medium_info_list_.count(); ++i) {
compaction::ObMediumCompactionInfo *medium_info = medium_info_list_[i]; compaction::ObMediumCompactionInfo *medium_info = medium_info_list_[i];
if (OB_ISNULL(medium_info)) { if (OB_ISNULL(medium_info)) {
ret = OB_ERR_UNEXPECTED;
LOG_ERROR("medium info kv is null", KP(medium_info), K(i)); LOG_ERROR("medium info kv is null", KP(medium_info), K(i));
} else { } else {
medium_info->reset(); medium_info->reset();