This is an automated email from the ASF dual-hosted git repository.

bdeggleston pushed a commit to branch cep-45-mutation-tracking
in repository https://gitbox.apache.org/repos/asf/cassandra.git

commit e7524acfecbeeb75163cefff42225c0b40ae414a
Author: Blake Eggleston <[email protected]>
AuthorDate: Mon Apr 13 10:43:50 2026 -0700

    rebase - fix CEP-45: Support host replacement with tracked keyspaces
---
 src/java/org/apache/cassandra/db/partitions/PartitionUpdate.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/java/org/apache/cassandra/db/partitions/PartitionUpdate.java 
b/src/java/org/apache/cassandra/db/partitions/PartitionUpdate.java
index a65d71cfcb..4f26c334bc 100644
--- a/src/java/org/apache/cassandra/db/partitions/PartitionUpdate.java
+++ b/src/java/org/apache/cassandra/db/partitions/PartitionUpdate.java
@@ -821,7 +821,7 @@ public class PartitionUpdate extends AbstractBTreePartition 
implements Commitabl
         {
             TableId tableId = TableId.deserialize(in);
             Epoch remoteVersion = null;
-            if (version >= MessagingService.VERSION_61)
+            if (version >= MessagingService.VERSION_60)
                 remoteVersion = Epoch.serializer.deserialize(in);
             TableMetadata tableMetadata = getTableMetadata(tableId, 
remoteVersion);
             UnfilteredRowIteratorSerializer.Header header = 
UnfilteredRowIteratorSerializer.serializer.deserializeHeader(tableMetadata, 
null, in, version, flag);
@@ -836,7 +836,7 @@ public class PartitionUpdate extends AbstractBTreePartition 
implements Commitabl
         {
             TableId tableId = TableId.deserialize(in);
             Epoch remoteVersion = null;
-            if (version >= MessagingService.VERSION_61)
+            if (version >= MessagingService.VERSION_60)
                 remoteVersion = Epoch.serializer.deserialize(in);
             TableMetadata tableMetadata = getTableMetadata(tableId, 
remoteVersion);
             UnfilteredRowIteratorSerializer.Header header = 
UnfilteredRowIteratorSerializer.serializer.deserializeHeader(tableMetadata, 
null, in, version, flag);


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to