fix parallel range
This commit is contained in:
@ -661,6 +661,7 @@ int ObMediumCompactionScheduleFunc::init_parallel_range_and_schema_changed(
|
|||||||
range.set_start_key(ObStoreRowkey::MIN_STORE_ROWKEY);
|
range.set_start_key(ObStoreRowkey::MIN_STORE_ROWKEY);
|
||||||
range.set_end_key(ObStoreRowkey::MAX_STORE_ROWKEY);
|
range.set_end_key(ObStoreRowkey::MAX_STORE_ROWKEY);
|
||||||
const bool is_major = medium_info.is_major_compaction();
|
const bool is_major = medium_info.is_major_compaction();
|
||||||
|
lib::CompatModeGuard g(tablet->get_tablet_meta().compat_mode_);
|
||||||
if (OB_FAIL(prepare_iter(result, table_iter))) {
|
if (OB_FAIL(prepare_iter(result, table_iter))) {
|
||||||
LOG_WARN("failed to get table iter", K(ret), K(range_array));
|
LOG_WARN("failed to get table iter", K(ret), K(range_array));
|
||||||
} else if (OB_FAIL(input_range_array.push_back(range))) {
|
} else if (OB_FAIL(input_range_array.push_back(range))) {
|
||||||
|
Reference in New Issue
Block a user