提交 db7a7afe 编写于 作者: J JiahuaChen 提交者: wangzelin.wzl

[CP] Add more logs for dropped tenant check information

上级 14a6af15
......@@ -31,6 +31,16 @@ public:
part_values_.reset();
}
TO_STRING_KV(K_(runner_server), K_(part_values));
int assign(const ServerOpInfo &other)
{
int ret = OB_SUCCESS;
if (OB_FAIL(part_values_.assign(other.part_values_))) {
LOG_WARN("assign part_values failed", K(ret), K(other));
} else {
runner_server_ = other.runner_server_;
}
return ret;
}
ObAddr runner_server_;
ObSEArray<PartValuesInfo, 1> part_values_;
......
......@@ -12660,6 +12660,9 @@ int ObPartitionService::check_tenant_pg_exist(const uint64_t tenant_id, bool& is
STORAGE_LOG(WARN, "get partition failed", K(ret));
} else if (partition->get_partition_key().get_tenant_id() == tenant_id) {
is_exist = true;
if (REACH_TIME_INTERVAL(60 * 1000 * 1000)) { // 1 minute
LOG_INFO("tenant partition exist", "pg_key", partition->get_partition_key());
}
break;
}
}
......
......@@ -129,6 +129,9 @@ int ObPGMemoryGarbageCollector::check_tenant_pg_exist(const uint64_t tenant_id,
{
ObIPartitionGroup* pg = curr->get_pg();
is_exist = pg->get_partition_key().get_tenant_id() == tenant_id;
if (REACH_TIME_INTERVAL(60 * 1000 * 1000)) { // 1 minute
LOG_INFO("tenant pg memory garbage exist", "pg_key", pg->get_partition_key());
}
}
return ret;
}
......
......@@ -1049,7 +1049,9 @@ int ObTableMgr::check_tenant_sstable_exist(const uint64_t tenant_id, bool& is_ex
ret = OB_ERR_SYS;
LOG_ERROR("node must not null", K(ret), KP(table));
} else if (!table->is_sstable()) {
// do nothing
if (REACH_TIME_INTERVAL(60 * 1000 * 1000)) { // 1 minute
LOG_INFO("tenant sstable exist", "table_key", table->get_key());
}
} else if (table->get_partition_key().get_tenant_id() == tenant_id) {
is_exist = true;
break;
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册