fix error code (vesoft-inc#5233)

Co-authored-by: Sophie <84560950+Sophie-Xie@users.noreply.github.com>
codesigner · Jan 11, 2023 · 9c1ff89 · 9c1ff89
1 parent 4015b39
commit 9c1ff89
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/src/meta/processors/job/RebuildJobExecutor.cpp b/src/meta/processors/job/RebuildJobExecutor.cpp
@@ -64,12 +64,12 @@ nebula::cpp2::ErrorCode RebuildJobExecutor::stop() {
   auto tries = folly::collectAll(std::move(futures)).get();
   if (std::any_of(tries.begin(), tries.end(), [](auto& t) { return t.hasException(); })) {
     LOG(INFO) << "RebuildJobExecutor::stop() RPC failure.";
-    return nebula::cpp2::ErrorCode::E_BALANCER_FAILURE;
+    return nebula::cpp2::ErrorCode::E_RPC_FAILURE;
   }
   for (const auto& t : tries) {
     if (!t.value().ok()) {
       LOG(INFO) << "Stop Build Index Failed";
-      return nebula::cpp2::ErrorCode::E_BALANCER_FAILURE;
+      return nebula::cpp2::ErrorCode::E_RPC_FAILURE;
     }
   }
   return nebula::cpp2::ErrorCode::SUCCEEDED;

diff --git a/src/meta/processors/job/StatsJobExecutor.cpp b/src/meta/processors/job/StatsJobExecutor.cpp
@@ -198,13 +198,13 @@ nebula::cpp2::ErrorCode StatsJobExecutor::stop() {
   auto tries = folly::collectAll(std::move(futures)).get();
   if (std::any_of(tries.begin(), tries.end(), [](auto& t) { return t.hasException(); })) {
     LOG(INFO) << "stats job stop() RPC failure.";
-    return nebula::cpp2::ErrorCode::E_BALANCER_FAILURE;
+    return nebula::cpp2::ErrorCode::E_RPC_FAILURE;
   }
 
   for (const auto& t : tries) {
     if (!t.value().ok()) {
       LOG(INFO) << "Stop stats job Failed";
-      return nebula::cpp2::ErrorCode::E_BALANCER_FAILURE;
+      return nebula::cpp2::ErrorCode::E_RPC_FAILURE;
     }
   }
   return nebula::cpp2::ErrorCode::SUCCEEDED;