fix baton miss reset in StorageJobExecutor (#5269)

vesoft-inc · Jan 28, 2023 · bcc7a83 · bcc7a83
1 parent 6f972c9
commit bcc7a83
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/meta/processors/job/StorageJobExecutor.cpp b/src/meta/processors/job/StorageJobExecutor.cpp
@@ -231,7 +231,7 @@ folly::Future<nebula::cpp2::ErrorCode> StorageJobExecutor::execute() {
                                            task.getErrorCode());
       faildKV.emplace_back(std::move(taskKey), std::move(taskVal));
     }
-
+    baton.reset();
     kvstore_->asyncMultiPut(
         kDefaultSpaceId, kDefaultPartId, std::move(faildKV), [&](nebula::cpp2::ErrorCode code) {
           if (code != nebula::cpp2::ErrorCode::SUCCEEDED) {