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

fix inc direct load mini sstable column checksums

Browse Source
This commit is contained in:
suz-yang
2024-07-30 06:32:33 +00:00
committed by ob-robot
parent f4249b7a85
commit 2537cc3bfa
1 changed files with 8 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
src/storage/tablet/ob_tablet_create_sstable_param.cpp
View File

@ -407,12 +407,14 @@ int ObTabletCreateSSTableParam::init_for_ddl(blocksstable::ObSSTableIndexBuilder
} }
} }
if (OB_FAIL(ret)) { if (OB_FAIL(ret)) {
} else if (OB_FAIL(column_checksums_.assign(res.data_column_checksums_))) { } else if (!is_incremental_direct_load(ddl_param.direct_load_type_)) {
LOG_WARN("fail to fill column checksum for empty major", K(ret), K(res.data_column_checksums_)); if (OB_FAIL(column_checksums_.assign(res.data_column_checksums_))) {
} else if (OB_UNLIKELY(column_checksums_.count() != column_count)) { LOG_WARN("fail to fill column checksum for empty major", K(ret), K(res.data_column_checksums_));
// we have corrected the col_default_checksum_array_ in prepare_index_data_desc } else if (OB_UNLIKELY(column_checksums_.count() != column_count)) {
ret = OB_ERR_UNEXPECTED; // we have corrected the col_default_checksum_array_ in prepare_index_data_desc
LOG_WARN("unexpected column checksums", K(ret), K(column_count), KPC(this)); ret = OB_ERR_UNEXPECTED;
LOG_WARN("unexpected column checksums", K(ret), K(column_count), KPC(this));
}
} }
} }
} }