Merge branch 'cassandra-4.1' into cassandra-5.0

Author: smiklosovic

CHANGES.txt

@@ -1,4 +1,6 @@
 5.0.9
+Merged from 4.0:
+ * Backport CASSANDRA-17810 fix and improve RTBoundValidator error messages (CASSANDRA-18282)
 
 
 5.0.8

src/java/org/apache/cassandra/db/ReadCommand.java

@@ -801,6 +801,7 @@ private UnfilteredPartitionIterator withQueryCancellation(UnfilteredPartitionIte
     /**
      *  A transformation used for simulating slow queries by tests.
      */
+    @VisibleForTesting
     private static class DelayInjector extends Transformation<UnfilteredRowIterator>
     {
         @Override

src/java/org/apache/cassandra/db/ReadCommandVerbHandler.java

@@ -19,6 +19,8 @@
 
 import java.util.concurrent.TimeUnit;
 
+import com.google.common.base.Preconditions;
+
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -115,7 +117,7 @@ public void doVerb(Message<ReadCommand> message)
         {
             logger.debug("Query cancelled (timeout)", e);
             response = null;
-            assert !command.isCompleted() : "Read marked as completed despite being aborted by timeout to table " + command.metadata();
+            Preconditions.checkState(!command.isCompleted(), "Read marked as completed despite being aborted by timeout to table %s", command.metadata());
         }
 
         if (command.complete())

src/java/org/apache/cassandra/db/transform/RTBoundValidator.java

@@ -25,7 +25,8 @@
 import org.apache.cassandra.db.rows.UnfilteredRowIterator;
 
 /**
- * A validating transformation that sanity-checks the sequence of RT bounds and boundaries in every partition.
+ * A validating transformation that sanity-checks the sequence of Range Tombstone bounds and boundaries in every
+ * partition.
  *
  * What we validate, specifically:
  * - that open markers are only followed by close markers
@@ -109,7 +110,7 @@ public RangeTombstoneMarker applyToMarker(RangeTombstoneMarker marker)
         public void onPartitionClose()
         {
             if (enforceIsClosed && null != openMarkerDeletionTime)
-                throw ise("expected all RTs to be closed, but the last one is open");
+                throw ise("expected all Range Tombstones to be closed, but the last one is open");
         }
 
         private IllegalStateException ise(String why)
@@ -119,7 +120,7 @@ private IllegalStateException ise(String why)
 
         private String message(String why)
         {
-            return String.format("%s UnfilteredRowIterator for %s (key: %s omdt: [%s]) has an illegal RT bounds sequence: %s",
+            return String.format("%s UnfilteredRowIterator for %s (key: %s omdt: [%s]) has an illegal Range Tombstone bounds sequence: %s",
                                  stage,
                                  partition.metadata(),
                                  partition.metadata().partitionKeyType.getString(partition.partitionKey().getKey()),

src/java/org/apache/cassandra/service/StorageProxy.java

@@ -2222,7 +2222,7 @@ protected void runMayThrow()
                 {
                     logger.debug("Query cancelled (timeout)", e);
                     response = null;
-                    assert !command.isCompleted() : "Local read marked as completed despite being aborted by timeout to table " + command.metadata();
+                    Preconditions.checkState(!command.isCompleted(), "Local read marked as completed despite being aborted by timeout to table %s", command.metadata());
                 }
 
                 if (command.complete())