diff --git a/src/meta/processors/job/StorageJobExecutor.cpp b/src/meta/processors/job/StorageJobExecutor.cpp
index 1934c7aedec..1d179fa4e8b 100644
--- 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) {