CASSANDRA-20901 fix typos

CHANGES.txt

@@ -8097,7 +8097,7 @@ Merged from 0.8:
  * avoid preserving login information after client disconnects
    (CASSANDRA-1057)
  * prefer sun jdk to openjdk in debian init script (CASSANDRA-1174)
- * detect partioner config changes between restarts and fail fast
+ * detect partitioner config changes between restarts and fail fast
    (CASSANDRA-1146)
  * use generation time to resolve node token reassignment disagreements
    (CASSANDRA-1118)

src/java/org/apache/cassandra/cql3/selection/ColumnFilterFactory.java

@@ -27,7 +27,7 @@
 /**
  * Factory for {@code ColumnFilter} instances.
  * <p>This class is used to abstract the fact that depending on the selection clause the {@code ColumnFilter} instances
- * can be computed at prepartion time (if all the requested columns are known) or must be computed at execution time.</p>
+ * can be computed at prepartition time (if all the requested columns are known) or must be computed at execution time.</p>
  */
 abstract class ColumnFilterFactory
 {

src/java/org/apache/cassandra/db/filter/TombstoneOverwhelmingException.java

@@ -31,7 +31,7 @@ public class TombstoneOverwhelmingException extends RejectException
 {
     public TombstoneOverwhelmingException(int numTombstones, String query, TableMetadata metadata, DecoratedKey lastPartitionKey, ClusteringPrefix<?> lastClustering)
     {
-        super(String.format("Scanned over %d tombstones during query '%s' (last scanned row token was %s and partion key was (%s)); query aborted",
+        super(String.format("Scanned over %d tombstones during query '%s' (last scanned row token was %s and partitioner key was (%s)); query aborted",
                             numTombstones, query, lastPartitionKey.getToken(), makePKString(metadata, lastPartitionKey.getKey(), lastClustering)));
     }
 

src/java/org/apache/cassandra/dht/Token.java

@@ -301,7 +301,7 @@ public long getLongValue()
      * between this token and it in the token order.
      *
      * This is not possible for all token types, esp. for comparison-based
-     * tokens such as the LocalPartioner used for classic secondary indexes.
+     * tokens such as the LocalPartitioner used for classic secondary indexes.
      *
      * Used to avoid clashes between nodes in separate datacentres trying to
      * use the same token via the token allocation algorithm, as well as in

src/java/org/apache/cassandra/gms/GossipDigestSyn.java

@@ -38,14 +38,14 @@ public class GossipDigestSyn
     public static final IVersionedSerializer<GossipDigestSyn> serializer = new GossipDigestSynSerializer();
 
     final String clusterId;
-    final String partioner;
+    final String partitioner;
     final int metadataId;
     final List<GossipDigest> gDigests;
 
-    public GossipDigestSyn(String clusterId, String partioner, int metadataId, List<GossipDigest> gDigests)
+    public GossipDigestSyn(String clusterId, String partitioner, int metadataId, List<GossipDigest> gDigests)
     {
         this.clusterId = clusterId;
-        this.partioner = partioner;
+        this.partitioner = partitioner;
         this.metadataId = metadataId;
         this.gDigests = gDigests;
     }
@@ -88,7 +88,7 @@ class GossipDigestSynSerializer implements IVersionedSerializer<GossipDigestSyn>
     public void serialize(GossipDigestSyn gDigestSynMessage, DataOutputPlus out, int version) throws IOException
     {
         out.writeUTF(gDigestSynMessage.clusterId);
-        out.writeUTF(gDigestSynMessage.partioner);
+        out.writeUTF(gDigestSynMessage.partitioner);
         if (version >= MessagingService.VERSION_51)
             out.writeUnsignedVInt32(gDigestSynMessage.metadataId);
         GossipDigestSerializationHelper.serialize(gDigestSynMessage.gDigests, out, version);
@@ -97,19 +97,19 @@ public void serialize(GossipDigestSyn gDigestSynMessage, DataOutputPlus out, int
     public GossipDigestSyn deserialize(DataInputPlus in, int version) throws IOException
     {
         String clusterId = in.readUTF();
-        String partioner = null;
-        partioner = in.readUTF();
+        String partitioner = null;
+        partitioner = in.readUTF();
         int metadataId = version >= MessagingService.VERSION_51
                          ? in.readUnsignedVInt32()
                          : ClusterMetadata.EMPTY_METADATA_IDENTIFIER;
         List<GossipDigest> gDigests = GossipDigestSerializationHelper.deserialize(in, version);
-        return new GossipDigestSyn(clusterId, partioner, metadataId, gDigests);
+        return new GossipDigestSyn(clusterId, partitioner, metadataId, gDigests);
     }
 
     public long serializedSize(GossipDigestSyn syn, int version)
     {
         long size = TypeSizes.sizeof(syn.clusterId);
-        size += TypeSizes.sizeof(syn.partioner);
+        size += TypeSizes.sizeof(syn.partitioner);
         if (version >= MessagingService.VERSION_51)
             size += TypeSizes.sizeofUnsignedVInt(syn.metadataId);
         size += GossipDigestSerializationHelper.serializedSize(syn.gDigests, version);

src/java/org/apache/cassandra/gms/GossipDigestSynVerbHandler.java

@@ -58,9 +58,9 @@ public void doVerb(Message<GossipDigestSyn> message)
             return;
         }
 
-        if (gDigestMessage.partioner != null && !gDigestMessage.partioner.equals(DatabaseDescriptor.getPartitionerName()))
+        if (gDigestMessage.partitioner != null && !gDigestMessage.partitioner.equals(DatabaseDescriptor.getPartitionerName()))
         {
-            logger.warn("Partitioner mismatch from {} {}!={}", from, gDigestMessage.partioner, DatabaseDescriptor.getPartitionerName());
+            logger.warn("Partitioner mismatch from {} {}!={}", from, gDigestMessage.partitioner, DatabaseDescriptor.getPartitionerName());
             return;
         }
 

src/java/org/apache/cassandra/service/paxos/uncommitted/UncommittedTableData.java

@@ -143,7 +143,7 @@ protected PaxosKeyState computeNext()
                 }
 
                 PaxosKeyState next = peeking.next();
-                // If repairing a table with a partioner different from IPartitioner.global(), such as the distributed
+                // If repairing a table with a partitioner different from IPartitioner.global(), such as the distributed
                 // metadata log table, we don't filter paxos keys outside the data range of the repair. Instead, we
                 // repair everything present for that table. Replicas of the distributed log table (i.e. CMS members)
                 // always replicate the entire table, so this is not much of an issue at present.

src/java/org/apache/cassandra/utils/MerkleTree.java

@@ -1531,7 +1531,7 @@ public static int estimatedMaxDepthForBytes(IPartitioner partitioner, long numBy
         Inner inner = new OnHeapInner(partitioner.getMinimumToken(), left, right);
         inner.fillInnerHashes();
 
-        // Some partioners have variable token sizes, try to estimate as close as we can by using the same
+        // Some partitioners have variable token sizes, try to estimate as close as we can by using the same
         // heap estimate as the memtables use.
         long innerTokenSize = ObjectSizes.measureDeep(partitioner.getMinimumToken());
         long realInnerTokenSize = partitioner.getMinimumToken().getHeapSize();

test/unit/org/apache/cassandra/io/sstable/ScrubTest.java

@@ -412,7 +412,7 @@ public void testScrubOneRowWithCorruptedKey() throws IOException, ConfigurationE
         if (BigFormat.is(sstable.descriptor.getFormat()))
             assertOrderedAll(cfs, 4);
         else if (BtiFormat.is(sstable.descriptor.getFormat()))
-            // For Trie format we won't be able to recover the damaged partition key (partion index doesn't store the whole key)
+            // For Trie format we won't be able to recover the damaged partition key (partitioner index doesn't store the whole key)
             assertOrderedAll(cfs, 3);
         else
             throw Util.testMustBeImplementedForSSTableFormat();