remove job metrics

vesoft-inc · Dec 22, 2021 · d693434 · d693434
1 parent 5a51953
commit d693434
Show file tree

Hide file tree

Showing 3 changed files with 0 additions and 6 deletions.
diff --git a/src/meta/MetaServiceHandler.h b/src/meta/MetaServiceHandler.h
@@ -25,8 +25,6 @@ class MetaServiceHandler final : public cpp2::MetaServiceSvIf {
 
     // Initialize counters
     kHBCounters.init();
-    kNumActiveJobs = stats::StatsManager::registerStats("num_active_jobs", "sum");
-    kNumRunningJobs = stats::StatsManager::registerStats("num_running_jobs", "sum");
   }
 
   /**

diff --git a/src/meta/processors/job/AdminJobProcessor.cpp b/src/meta/processors/job/AdminJobProcessor.cpp
@@ -12,7 +12,6 @@
 
 namespace nebula {
 namespace meta {
-stats::CounterId kNumActiveJobs;
 
 void AdminJobProcessor::process(const cpp2::AdminJobReq& req) {
   cpp2::AdminJobResult result;
@@ -61,7 +60,6 @@ void AdminJobProcessor::process(const cpp2::AdminJobReq& req) {
       errorCode = jobMgr->addJob(jobDesc, adminClient_);
       if (errorCode == nebula::cpp2::ErrorCode::SUCCEEDED) {
         result.set_job_id(nebula::value(jobId));
-        stats::StatsManager::addValue(kNumActiveJobs);
       }
       break;
     }
@@ -124,7 +122,6 @@ void AdminJobProcessor::process(const cpp2::AdminJobReq& req) {
       auto ret = jobMgr->recoverJob(spaceName, adminClient_, jobIds);
       if (nebula::ok(ret)) {
         result.set_recovered_job_num(nebula::value(ret));
-        stats::StatsManager::addValue(kNumActiveJobs);
       } else {
         errorCode = nebula::error(ret);
       }

diff --git a/src/meta/processors/job/AdminJobProcessor.h b/src/meta/processors/job/AdminJobProcessor.h
@@ -12,7 +12,6 @@
 
 namespace nebula {
 namespace meta {
-extern stats::CounterId kNumActiveJobs;
 
 class AdminJobProcessor : public BaseProcessor<cpp2::AdminJobResp> {
  public: