diff --git a/core/CHANGELOG.md b/core/CHANGELOG.md index 13248265d7..2467013ba9 100644 --- a/core/CHANGELOG.md +++ b/core/CHANGELOG.md @@ -17,6 +17,8 @@ Please mark all change in change log and use the ticket from JIRA. - MS-640 - Cache object size calculate incorrect - MS-641 - Segment fault(signal 11) in PickToLoad - MS-639 - SQ8H index created failed and server hang +- MS-647 - [monitor] grafana display average cpu-temp +- MS-644 - Search crashed with index-type: flat - MS-624 - Search vectors failed if time ranges long enough ## Improvement diff --git a/core/src/metrics/PrometheusMetrics.cpp b/core/src/metrics/PrometheusMetrics.cpp index 182f14d46c..770b34dc47 100644 --- a/core/src/metrics/PrometheusMetrics.cpp +++ b/core/src/metrics/PrometheusMetrics.cpp @@ -222,10 +222,19 @@ PrometheusMetrics::CPUTemperature() { std::vector CPU_temperatures = server::SystemInfo::GetInstance().CPUTemperature(); + float avg_cpu_temp = 0; for (int i = 0; i < CPU_temperatures.size(); ++i) { - prometheus::Gauge& cpu_temp = CPU_temperature_.Add({{"CPU", std::to_string(i)}}); - cpu_temp.Set(CPU_temperatures[i]); + avg_cpu_temp += CPU_temperatures[i]; } + avg_cpu_temp /= CPU_temperatures.size(); + + prometheus::Gauge& cpu_temp = CPU_temperature_.Add({{"CPU", std::to_string(0)}}); + cpu_temp.Set(avg_cpu_temp); + + // for (int i = 0; i < CPU_temperatures.size(); ++i) { + // prometheus::Gauge& cpu_temp = CPU_temperature_.Add({{"CPU", std::to_string(i)}}); + // cpu_temp.Set(CPU_temperatures[i]); + // } } void diff --git a/core/src/scheduler/action/PushTaskToNeighbour.cpp b/core/src/scheduler/action/PushTaskToNeighbour.cpp index b42234d0f6..7fbcf77afc 100644 --- a/core/src/scheduler/action/PushTaskToNeighbour.cpp +++ b/core/src/scheduler/action/PushTaskToNeighbour.cpp @@ -110,16 +110,18 @@ Action::DefaultLabelTaskScheduler(ResourceMgrWPtr res_mgr, ResourcePtr resource, bool moved = false; // to support test task, REFACTOR - if (auto index_engine = search_task->index_engine_) { - auto location = index_engine->GetLocation(); + if (resource->type() == ResourceType::CPU) { + if (auto index_engine = search_task->index_engine_) { + auto location = index_engine->GetLocation(); - for (auto i = 0; i < res_mgr.lock()->GetNumGpuResource(); ++i) { - auto index = milvus::cache::GpuCacheMgr::GetInstance(i)->GetIndex(location); - if (index != nullptr) { - moved = true; - auto dest_resource = res_mgr.lock()->GetResource(ResourceType::GPU, i); - PushTaskToResource(event->task_table_item_->task, dest_resource); - break; + for (auto i = 0; i < res_mgr.lock()->GetNumGpuResource(); ++i) { + auto index = milvus::cache::GpuCacheMgr::GetInstance(i)->GetIndex(location); + if (index != nullptr) { + moved = true; + auto dest_resource = res_mgr.lock()->GetResource(ResourceType::GPU, i); + PushTaskToResource(event->task_table_item_->task, dest_resource); + break; + } } } }