From d17aa4b32c4ba697190509e0140a726d483ad4f2 Mon Sep 17 00:00:00 2001 From: chuxing Date: Sat, 27 Mar 2021 15:47:36 +0800 Subject: [PATCH 1/2] fix hccl --- ge/hybrid/model/hybrid_model_builder.cc | 1 + 1 file changed, 1 insertion(+) diff --git a/ge/hybrid/model/hybrid_model_builder.cc b/ge/hybrid/model/hybrid_model_builder.cc index f1f28010..eebda47c 100755 --- a/ge/hybrid/model/hybrid_model_builder.cc +++ b/ge/hybrid/model/hybrid_model_builder.cc @@ -1097,6 +1097,7 @@ Status HybridModelBuilder::LoadTasks() { } if (node_item->node_type == PARTITIONEDCALL) { ordered_partitioned_calls.emplace(node_item->node_id, node_item.get()); + continue; } GE_CHK_STATUS_RET_NOLOG(LoadTask(*node_item)); } From 61f1cf34a59a8202e164082a6faddf0bdbb04c84 Mon Sep 17 00:00:00 2001 From: chuxing Date: Sat, 27 Mar 2021 16:11:49 +0800 Subject: [PATCH 2/2] opt log --- ge/hybrid/model/hybrid_model_builder.cc | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/ge/hybrid/model/hybrid_model_builder.cc b/ge/hybrid/model/hybrid_model_builder.cc index eebda47c..669fafb1 100755 --- a/ge/hybrid/model/hybrid_model_builder.cc +++ b/ge/hybrid/model/hybrid_model_builder.cc @@ -2030,14 +2030,14 @@ Status HybridModelBuilder::CollectParallelGroups(NodeItem *node_item) { if (executor_type == NodeExecutorManager::ExecutorType::HCCL) { std::string parallel_group; if (AttrUtils::GetStr(node->GetOpDesc(), ATTR_NAME_PARALLEL_GROUP, parallel_group)) { - GELOGD("[%s] Got parallel group = %s", node_item->NodeName().c_str(), parallel_group.c_str()); + GELOGD("[%s] Got parallel group = [%s]", node_item->NodeName().c_str(), parallel_group.c_str()); parallel_group_to_nodes_[parallel_group].emplace(node_item); std::set group{parallel_group}; node_to_parallel_groups_[node_item].emplace(parallel_group); } } else if (executor_type == NodeExecutorManager::ExecutorType::COMPILED_SUBGRAPH) { std::set parallel_groups; - GELOGD("[%s] Parse parallel group for known-shaped subgraph", node_item->NodeName().c_str()); + GELOGD("[%s] To collect parallel group for known-shaped subgraph", node_item->NodeName().c_str()); for (const auto &subgraph_name : node->GetOpDesc()->GetSubgraphInstanceNames()) { GELOGD("[%s] Start to get parallel group from subgraph: %s", node_item->NodeName().c_str(),