add allocator tenant label & avoid print error log
This commit is contained in:
@ -44,7 +44,7 @@ ObTabletMergeInfo::ObTabletMergeInfo()
|
|||||||
bloom_filter_block_ctx_(nullptr),
|
bloom_filter_block_ctx_(nullptr),
|
||||||
bloomfilter_block_id_(),
|
bloomfilter_block_id_(),
|
||||||
sstable_merge_info_(),
|
sstable_merge_info_(),
|
||||||
allocator_("MergeContext", OB_MALLOC_MIDDLE_BLOCK_SIZE),
|
allocator_("MergeContext", OB_MALLOC_MIDDLE_BLOCK_SIZE, MTL_ID()),
|
||||||
index_builder_(nullptr)
|
index_builder_(nullptr)
|
||||||
{
|
{
|
||||||
}
|
}
|
||||||
|
|||||||
@ -190,7 +190,7 @@ ObBasicTabletMergeDag::ObBasicTabletMergeDag(
|
|||||||
compat_mode_(lib::Worker::CompatMode::INVALID),
|
compat_mode_(lib::Worker::CompatMode::INVALID),
|
||||||
ctx_(nullptr),
|
ctx_(nullptr),
|
||||||
param_(),
|
param_(),
|
||||||
allocator_("MergeDag")
|
allocator_("MergeDag", OB_MALLOC_NORMAL_BLOCK_SIZE, MTL_ID())
|
||||||
{
|
{
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -1308,7 +1308,7 @@ int ObTabletMergeFinishTask::try_schedule_compaction_after_mini(
|
|||||||
|
|
||||||
ObTabletMergeTask::ObTabletMergeTask()
|
ObTabletMergeTask::ObTabletMergeTask()
|
||||||
: ObITask(ObITask::TASK_TYPE_MACROMERGE),
|
: ObITask(ObITask::TASK_TYPE_MACROMERGE),
|
||||||
allocator_(),
|
allocator_("MergeTask", OB_MALLOC_NORMAL_BLOCK_SIZE, MTL_ID()),
|
||||||
idx_(0),
|
idx_(0),
|
||||||
ctx_(nullptr),
|
ctx_(nullptr),
|
||||||
merger_(nullptr),
|
merger_(nullptr),
|
||||||
|
|||||||
@ -842,7 +842,7 @@ int ObStorageHATabletsBuilder::hold_local_reuse_sstable_(
|
|||||||
} else if (OB_FAIL(hold_local_complete_tablet_sstable_(tablet, tables_handle))) {
|
} else if (OB_FAIL(hold_local_complete_tablet_sstable_(tablet, tables_handle))) {
|
||||||
LOG_WARN("failed to hold local complete tablet sstable", K(ret), KP(tablet));
|
LOG_WARN("failed to hold local complete tablet sstable", K(ret), KP(tablet));
|
||||||
} else {
|
} else {
|
||||||
if (!storage_schema.is_valid()
|
if (!storage_schema.is_inited()
|
||||||
|| storage_schema.get_schema_version() < tablet->get_storage_schema().get_schema_version()) {
|
|| storage_schema.get_schema_version() < tablet->get_storage_schema().get_schema_version()) {
|
||||||
storage_schema.reset();
|
storage_schema.reset();
|
||||||
if (OB_FAIL(storage_schema.init(allocator, tablet->get_storage_schema()))) {
|
if (OB_FAIL(storage_schema.init(allocator, tablet->get_storage_schema()))) {
|
||||||
|
|||||||
@ -98,7 +98,7 @@ class ObStorageSchema : public share::schema::ObMergeSchema, public memtable::Ob
|
|||||||
public:
|
public:
|
||||||
ObStorageSchema();
|
ObStorageSchema();
|
||||||
virtual ~ObStorageSchema();
|
virtual ~ObStorageSchema();
|
||||||
|
bool is_inited() const { return is_inited_; }
|
||||||
int init(
|
int init(
|
||||||
common::ObIAllocator &allocator,
|
common::ObIAllocator &allocator,
|
||||||
const share::schema::ObTableSchema &input_schema,
|
const share::schema::ObTableSchema &input_schema,
|
||||||
|
|||||||
Reference in New Issue
Block a user