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 3c2b1db6d0b970da794d80c922ae711d84f99ed4..2e9f54f1e249beb0cfc4c5ec63ef00d5d4e232a7 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 5c85cb953c25c211e51576d3fd652f2af61e0983..fa2f44810903875c6bf31de0bfaedc00c148c01a 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 58691014bb1431925e8db9699b440184a060996d..6fc6c9e7e031a61210e131ed679a2771d2c90b5a 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 6a2ef4a3148faaf697c9b48f4026f843446d884e..2ea56dcfe88f45522680855445b2472f5587ddd6 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;