[jira] [Created] (CASSANDRA-20972) DISTINCT queries failing with range tombstones

["Marcus Eriksson (Jira)" <ji...@apache.org>]

Marcus Eriksson created CASSANDRA-20972:
-------------------------------------------

             Summary: DISTINCT queries failing with range tombstones
                 Key: CASSANDRA-20972
                 URL: https://issues.apache.org/jira/browse/CASSANDRA-20972
             Project: Apache Cassandra
          Issue Type: Bug
          Components: Local/SSTable
            Reporter: Marcus Eriksson
            Assignee: Marcus Eriksson


Queries like {{select distinct id from %s.tbl where token(id) > 0}} fail if there is an overlapping range tombstone:
{code}
ERROR 10:35:30 Exception in thread Thread[node1_ReadStage-1,5,SharedPool]
java.lang.RuntimeException: java.lang.IllegalStateException: The UnfilteredRowIterator returned by the last call to next() was initialized: it must be closed before calling hasNext() or next() again.
	at org.apache.cassandra.service.StorageProxy$DroppableRunnable.run(StorageProxy.java:2612)
	at org.apache.cassandra.concurrent.ExecutionFailure$2.run(ExecutionFailure.java:163)
	at org.apache.cassandra.concurrent.SEPWorker.run(SEPWorker.java:143)
	at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
	at java.base/java.lang.Thread.run(Thread.java:829)
Caused by: java.lang.IllegalStateException: The UnfilteredRowIterator returned by the last call to next() was initialized: it must be closed before calling hasNext() or next() again.
	at org.apache.cassandra.io.sstable.format.SSTableScanner$BaseKeyScanningIterator.computeNext(SSTableScanner.java:241)
	at org.apache.cassandra.io.sstable.format.SSTableScanner$BaseKeyScanningIterator.computeNext(SSTableScanner.java:228)
	at org.apache.cassandra.utils.AbstractIterator.hasNext(AbstractIterator.java:47)
	at org.apache.cassandra.io.sstable.format.SSTableScanner.hasNext(SSTableScanner.java:190)
	at org.apache.cassandra.db.transform.BasePartitions.hasNext(BasePartitions.java:90)
	at org.apache.cassandra.utils.MergeIterator$Candidate.advance(MergeIterator.java:375)
	at org.apache.cassandra.utils.MergeIterator$ManyToOne.advance(MergeIterator.java:187)
	at org.apache.cassandra.utils.MergeIterator$ManyToOne.computeNext(MergeIterator.java:156)
{code}

Reason is that when {{LazilyInitializedUnfilteredRowIterator}} is closed the underlying iterator is nulled out, this allows the iterator to be re-initialized if anyone accesses a method that calls {{maybeInit}}, like {{isReverseOrder()}} which is called when adding an artificial range tombstone bound closer.

This was caused by CASSANDRA-18398



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@cassandra.apache.org
For additional commands, e-mail: commits-help@cassandra.apache.org