diff --git a/src/java/org/apache/cassandra/tcm/sequences/InProgressSequences.java b/src/java/org/apache/cassandra/tcm/sequences/InProgressSequences.java index a8b2b16259..86b449c346 100644 --- a/src/java/org/apache/cassandra/tcm/sequences/InProgressSequences.java +++ b/src/java/org/apache/cassandra/tcm/sequences/InProgressSequences.java @@ -223,7 +223,7 @@ public class InProgressSequences implements MetadataValue out.writeInt(t.state.size()); for (Map.Entry> entry : t.state.entrySet()) { - if (Version.UNKNOWN.isBefore(V2)) + if (version.isBefore(V2)) { NodeId.serializer.serialize((NodeId) entry.getKey(), out, version); MultiStepOperation seq = entry.getValue(); @@ -249,7 +249,7 @@ public class InProgressSequences implements MetadataValue ImmutableMap.Builder> res = ImmutableMap.builder(); for (int i = 0; i < ipsSize; i++) { - if (Version.UNKNOWN.isBefore(V2)) + if (version.isBefore(V2)) { NodeId nodeId = NodeId.serializer.deserialize(in, version); MultiStepOperation.Kind kind = MultiStepOperation.Kind.valueOf(in.readUTF()); @@ -273,7 +273,7 @@ public class InProgressSequences implements MetadataValue size += sizeof(t.state.size()); for (Map.Entry> entry : t.state.entrySet()) { - if (Version.UNKNOWN.isBefore(V2)) + if (version.isBefore(V2)) { size += NodeId.serializer.serializedSize((NodeId) entry.getKey(), version); MultiStepOperation seq = entry.getValue();