Remove improper iterator copy in digest calculation

whangsf · Dec 11, 2017 · d6ec955 · d6ec955
1 parent 8547f74
commit d6ec955
Showing 1 changed file with 3 additions and 6 deletions.
diff --git a/src/java/org/apache/cassandra/db/partitions/UnfilteredPartitionIterators.java b/src/java/org/apache/cassandra/db/partitions/UnfilteredPartitionIterators.java
@@ -240,14 +240,11 @@ public void close()
      */
     public static void digest(UnfilteredPartitionIterator iterator, Hasher hasher, int version)
     {
-        try (UnfilteredPartitionIterator iter = iterator)
+        while (iterator.hasNext())
         {
-            while (iter.hasNext())
+            try (UnfilteredRowIterator partition = iterator.next())
             {
-                try (UnfilteredRowIterator partition = iter.next())
-                {
-                    UnfilteredRowIterators.digest(partition, hasher, version);
-                }
+                UnfilteredRowIterators.digest(partition, hasher, version);
             }
         }
     }