Reset repairedAt when receiving sstables

We're not using incremental repairs, therefore we want Repaired At to be set to 0 for all sstables. Some older services still have this value set to non-zero values from the times when we were using incremental repairs. This patch should make sure that any new node we bootstrap has Repaired At set to 0 for all sstables. This patch should be removed when we release the next minor version after 4.1.7.
aiven · Nov 5, 2024 · 3b527b1 · 3b527b1
1 parent 59987dc
commit 3b527b1
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/src/java/org/apache/cassandra/db/streaming/CassandraEntireSSTableStreamReader.java b/src/java/org/apache/cassandra/db/streaming/CassandraEntireSSTableStreamReader.java
@@ -135,9 +135,9 @@ public SSTableMultiWriter read(DataInputPlus in) throws Throwable
             }
 
             UnaryOperator<StatsMetadata> transform = stats -> stats.mutateLevel(header.sstableLevel)
-                                                                   .mutateRepairedMetadata(messageHeader.repairedAt, messageHeader.pendingRepair, false);
+                                                                   .mutateRepairedMetadata(0, messageHeader.pendingRepair, false);
             String description = String.format("level %s and repairedAt time %s and pendingRepair %s",
-                                               header.sstableLevel, messageHeader.repairedAt, messageHeader.pendingRepair);
+                                               header.sstableLevel, 0, messageHeader.pendingRepair);
             writer.descriptor.getMetadataSerializer().mutate(writer.descriptor, description, transform);
             return writer;
         }

diff --git a/src/java/org/apache/cassandra/db/streaming/CassandraStreamReader.java b/src/java/org/apache/cassandra/db/streaming/CassandraStreamReader.java
@@ -102,7 +102,7 @@ public CassandraStreamReader(StreamMessageHeader header, CassandraStreamHeader s
         this.estimatedKeys = streamHeader.estimatedKeys;
         this.sections = streamHeader.sections;
         this.inputVersion = streamHeader.version;
-        this.repairedAt = header.repairedAt;
+        this.repairedAt = 0;
         this.pendingRepair = header.pendingRepair;
         this.format = streamHeader.format;
         this.sstableLevel = streamHeader.sstableLevel;