[fix][coordinator] Fix GetSchemaByName.

Signed-off-by: Ketor <d.ketor@gmail.com>
DataCanvasIO · Mar 7, 2024 · 8ff0279 · 8ff0279
1 parent b10daa2
commit 8ff0279
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 2 deletions.
diff --git a/src/client/coordinator_client_function_meta.cc b/src/client/coordinator_client_function_meta.cc
@@ -153,6 +153,8 @@ void SendGetSchemaByName(std::shared_ptr<dingodb::CoordinatorInteraction> coordi
     request.set_tenant_id(FLAGS_tenant_id);
   }
 
+  DINGO_LOG(INFO) << "SendRequest: " << request.DebugString();
+
   auto status = coordinator_interaction->SendRequest("GetSchemaByName", request, response);
   DINGO_LOG(INFO) << "SendRequest status=" << status;
   DINGO_LOG(INFO) << response.DebugString();

diff --git a/src/coordinator/coordinator_control_fsm.cc b/src/coordinator/coordinator_control_fsm.cc
@@ -77,8 +77,9 @@ void CoordinatorControl::BuildTempMaps() {
     butil::FlatMap<int64_t, pb::coordinator_internal::SchemaInternal> schema_map_copy;
     schema_map_copy.init(10000);
     schema_map_.GetRawMapCopy(schema_map_copy);
-    for (const auto& it : schema_map_copy) {
-      schema_name_map_safe_temp_.Put(it.second.name(), it.first);
+    for (const auto& [schema_id, schema_internal] : schema_map_copy) {
+      auto new_check_name = Helper::GenNewTenantCheckName(schema_internal.tenant_id(), schema_internal.name());
+      schema_name_map_safe_temp_.Put(new_check_name, schema_id);
     }
   }
   DINGO_LOG(INFO) << "schema_name_map_safe_temp, count=" << schema_name_map_safe_temp_.Size();