From db7a7afe45d053ea6f9daddfba463899d30b83ec Mon Sep 17 00:00:00 2001 From: JiahuaChen Date: Tue, 16 Aug 2022 11:50:36 +0800 Subject: [PATCH] [CP] Add more logs for dropped tenant check information --- src/sql/engine/dml/ob_multi_dml_plan_mgr.cpp | 10 ++++++++++ src/storage/ob_partition_service.cpp | 3 +++ src/storage/ob_pg_memory_garbage_collector.cpp | 3 +++ src/storage/ob_table_mgr.cpp | 4 +++- 4 files changed, 19 insertions(+), 1 deletion(-) diff --git a/src/sql/engine/dml/ob_multi_dml_plan_mgr.cpp b/src/sql/engine/dml/ob_multi_dml_plan_mgr.cpp index 3c2b1db6d..2e9f54f1e 100644 --- a/src/sql/engine/dml/ob_multi_dml_plan_mgr.cpp +++ b/src/sql/engine/dml/ob_multi_dml_plan_mgr.cpp @@ -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 part_values_; diff --git a/src/storage/ob_partition_service.cpp b/src/storage/ob_partition_service.cpp index 5c85cb953..fa2f44810 100644 --- a/src/storage/ob_partition_service.cpp +++ b/src/storage/ob_partition_service.cpp @@ -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; } } diff --git a/src/storage/ob_pg_memory_garbage_collector.cpp b/src/storage/ob_pg_memory_garbage_collector.cpp index 58691014b..6fc6c9e7e 100644 --- a/src/storage/ob_pg_memory_garbage_collector.cpp +++ b/src/storage/ob_pg_memory_garbage_collector.cpp @@ -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; } diff --git a/src/storage/ob_table_mgr.cpp b/src/storage/ob_table_mgr.cpp index 6a2ef4a31..2ea56dcfe 100644 --- a/src/storage/ob_table_mgr.cpp +++ b/src/storage/ob_table_mgr.cpp @@ -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; -- GitLab