return paritition in applyToPartition in QueryCancellationChecker ins…

…tead of adding stopping transformation at the end of the stack
apache · Dec 9, 2024 · fad5823 · fad5823
1 parent 8e35519
commit fad5823
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/java/org/apache/cassandra/db/ReadCommand.java b/src/java/org/apache/cassandra/db/ReadCommand.java
@@ -755,7 +755,7 @@ private class QueryCancellationChecker extends StoppingTransformation<Unfiltered
         protected UnfilteredRowIterator applyToPartition(UnfilteredRowIterator partition)
         {
             maybeCancel();
-            return Transformation.apply(partition, this);
+            return partition;
         }
 
         @Override
@@ -798,7 +798,7 @@ private static class DelayInjector extends Transformation<UnfilteredRowIterator>
         protected UnfilteredRowIterator applyToPartition(UnfilteredRowIterator partition)
         {
             FBUtilities.sleepQuietly(TEST_ITERATION_DELAY_MILLIS);
-            return Transformation.apply(partition, this);
+            return partition;
         }
 
         @Override