diff --git a/fdbserver/ApplyMetadataMutation.cpp b/fdbserver/ApplyMetadataMutation.cpp index 0fe2ae8125..a60130c9d2 100644 --- a/fdbserver/ApplyMetadataMutation.cpp +++ b/fdbserver/ApplyMetadataMutation.cpp @@ -803,7 +803,7 @@ private: .detail("Tag", tag.toString()) .detail("Server", decodeServerTagKey(kv.key)); if (!forResolver) { - logSystem->pop(popVersion, decodeServerTagValue(kv.value)); + logSystem->pop(popVersion, tag); (*tag_popped)[tag] = popVersion; } ASSERT_WE_THINK(forResolver ^ (tag_popped != nullptr)); @@ -811,11 +811,11 @@ private: if (toCommit) { MutationRef privatized = m; privatized.param1 = kv.key.withPrefix(systemKeys.begin, arena); - privatized.param2 = keyAfter(kv.key, arena).withPrefix(systemKeys.begin, arena); + privatized.param2 = keyAfter(privatized.param1, arena); TraceEvent(SevDebug, "SendingPrivatized_ClearServerTag", dbgid).detail("M", privatized); - toCommit->addTag(decodeServerTagValue(kv.value)); + toCommit->addTag(tag); writeMutation(privatized); } }