[BUG.FIX] fix error code overwrite
This commit is contained in:
@ -431,7 +431,7 @@ int ObTablet::init_for_merge(
|
|||||||
ddl_kvs_ = ddl_kvs_addr;
|
ddl_kvs_ = ddl_kvs_addr;
|
||||||
ddl_kv_count_ = ddl_kv_count;
|
ddl_kv_count_ = ddl_kv_count;
|
||||||
ALLOC_AND_INIT(allocator, table_store_addr_, (*this), param, (*old_table_store));
|
ALLOC_AND_INIT(allocator, table_store_addr_, (*this), param, (*old_table_store));
|
||||||
if (OB_UNLIKELY(ddl_kv_count_ != ddl_kv_count
|
if (OB_SUCC(ret) && OB_UNLIKELY(ddl_kv_count_ != ddl_kv_count
|
||||||
|| ddl_kv_count != table_store_addr_.get_ptr()->get_ddl_memtable_count())) {
|
|| ddl_kv_count != table_store_addr_.get_ptr()->get_ddl_memtable_count())) {
|
||||||
// This is defense code. If it runs at here, it must be a bug.
|
// This is defense code. If it runs at here, it must be a bug.
|
||||||
ret = OB_ERR_UNEXPECTED;
|
ret = OB_ERR_UNEXPECTED;
|
||||||
|
|||||||
Reference in New Issue
Block a user