diff --git a/src/storage/mutate/AddEdgesProcessor.cpp b/src/storage/mutate/AddEdgesProcessor.cpp index 32c59b8cba9..e3a20e9616c 100644 --- a/src/storage/mutate/AddEdgesProcessor.cpp +++ b/src/storage/mutate/AddEdgesProcessor.cpp @@ -144,6 +144,7 @@ void AddEdgesProcessor::doProcess(const cpp2::AddEdgesRequest& req) { if (code != nebula::cpp2::ErrorCode::SUCCEEDED) { handleAsync(spaceId_, partId, code); } else { + stats::StatsManager::addValue(kNumEdgesInserted, data.size()); if (consistOp_) { auto batchHolder = std::make_unique(); (*consistOp_)(*batchHolder, &data); @@ -155,7 +156,6 @@ void AddEdgesProcessor::doProcess(const cpp2::AddEdgesRequest& req) { }); } else { doPut(spaceId_, partId, std::move(data)); - stats::StatsManager::addValue(kNumEdgesInserted, data.size()); } } } diff --git a/src/storage/mutate/AddVerticesProcessor.cpp b/src/storage/mutate/AddVerticesProcessor.cpp index 8e8e380506e..38ac53100c2 100644 --- a/src/storage/mutate/AddVerticesProcessor.cpp +++ b/src/storage/mutate/AddVerticesProcessor.cpp @@ -143,8 +143,8 @@ void AddVerticesProcessor::doProcess(const cpp2::AddVerticesRequest& req) { if (code != nebula::cpp2::ErrorCode::SUCCEEDED) { handleAsync(spaceId_, partId, code); } else { - doPut(spaceId_, partId, std::move(data)); stats::StatsManager::addValue(kNumVerticesInserted, data.size()); + doPut(spaceId_, partId, std::move(data)); } } } @@ -213,7 +213,7 @@ void AddVerticesProcessor::doProcessWithIndex(const cpp2::AddVerticesRequest& re if (code != nebula::cpp2::ErrorCode::SUCCEEDED) { handleAsync(spaceId_, partId, code); } else { - stats::StatsManager::addValue(kNumVerticesInserted, verticeData.size()); + stats::StatsManager::addValue(kNumVerticesInserted, tags.size()); auto atomicOp = [=, tags = std::move(tags), vertices = std::move(verticeData)]() mutable { return addVerticesWithIndex(partId, tags, vertices); };