diff --git a/fdbserver/CommitProxyServer.actor.cpp b/fdbserver/CommitProxyServer.actor.cpp index bd5e152587..9492727cf5 100644 --- a/fdbserver/CommitProxyServer.actor.cpp +++ b/fdbserver/CommitProxyServer.actor.cpp @@ -1120,8 +1120,7 @@ ACTOR Future<Void> assignMutationsToStorageServers(CommitBatchContext* self) { DEBUG_MUTATION("ProxyCommit", self->commitVersion, m) .detail("Dbgid", pProxyCommitData->dbgid) - .detail("To", allSources) - .detail("Mutation", m); + .detail("To", allSources); self->toCommit.addTags(allSources); } @@ -1221,8 +1220,6 @@ ACTOR Future<Void> postResolution(CommitBatchContext* self) { // Second pass wait(assignMutationsToStorageServers(self)); - self->toCommit.saveTags(self->writtenTags); - // Serialize and backup the mutations as a single mutation if ((pProxyCommitData->vecBackupKeys.size() > 1) && self->logRangeMutations.size()) { wait(addBackupMutations(pProxyCommitData, @@ -1233,6 +1230,8 @@ ACTOR Future<Void> postResolution(CommitBatchContext* self) { &self->computeStart)); } + self->toCommit.saveTags(self->writtenTags); + pProxyCommitData->stats.mutations += self->mutationCount; pProxyCommitData->stats.mutationBytes += self->mutationBytes;