Marten Kenbeek created CASSANDRA-17403:
------------------------------------------
Summary: UnsupportedOperationException when serializing
EmptyCellPath for SliceRange query
Key: CASSANDRA-17403
URL: https://issues.apache.org/jira/browse/CASSANDRA-17403
Project: Cassandra
Issue Type: Bug
Reporter: Marten Kenbeek
When querying a supercolumn table for a slice of sub columns through Thrift, an
empty bound can be used as the start and/or finish in the SliceRange to create
a (half) unbounded slice. These bounds are translated to CellPath.BOTTOM/TOP
when [making the column filter in
CassandraServer|https://github.com/apache/cassandra/blob/c3d51a825cd16ca627b24c4190017cf4b4f320c2/src/java/org/apache/cassandra/thrift/CassandraServer.java#L437].
{code:java}
ByteBuffer key = UTF_8.encode("key");
ColumnParent parent = new
ColumnParent(tableName).setSuper_column(UTF_8.encode("Default"));
SliceRange range = new SliceRange(UTF_8.encode(""), UTF_8.encode(""), false,
100);
SlicePredicate predicate = new SlicePredicate().setSlice_range(range);
List<ColumnOrSuperColumn> columns = cassandra.get_slice(key, parent, predicate,
ConsistencyLevel.QUORUM);{code}
This query works fine on Cassandra 2.2. On 3.11 it works with consistency level
ONE, but fails when run on a cluster at a higher consistency level. When
attempting to send the (digest) requests to the other nodes, it cannot
serialize the EmptyCellPath and fails with the following stacktrace:
{code:java}
ERROR [Thrift:4112] 2022-02-24 12:31:10,989 CustomTThreadPoolServer.java:225 -
Error occurred during processing of message.
java.lang.UnsupportedOperationException: null
at
org.apache.cassandra.db.rows.CellPath$EmptyCellPath.get(CellPath.java:143)
~[apache-cassandra-3.11.11.jar:3.11.11]
at
org.apache.cassandra.db.marshal.CollectionType$CollectionPathSerializer.serializedSize(CollectionType.java:253)
~[apache-cassandra-3.11.11.jar:3.11.11]
at
org.apache.cassandra.db.filter.ColumnSubselection$Serializer.serializedSize(ColumnSubselection.java:228)
~[apache-cassandra-3.11.11.jar:3.11.11]
at
org.apache.cassandra.db.filter.ColumnFilter$Serializer.serializedSize(ColumnFilter.java:566)
~[apache-cassandra-3.11.11.jar:3.11.11]
at
org.apache.cassandra.db.ReadCommand$Serializer.serializedSize(ReadCommand.java:800)
~[apache-cassandra-3.11.11.jar:3.11.11]
at
org.apache.cassandra.db.ReadCommand$Serializer.serializedSize(ReadCommand.java:704)
~[apache-cassandra-3.11.11.jar:3.11.11]
at
org.apache.cassandra.io.ForwardingVersionedSerializer.serializedSize(ForwardingVersionedSerializer.java:55)
~[apache-cassandra-3.11.11.jar:3.11.11]
at org.apache.cassandra.net.MessageOut.payloadSize(MessageOut.java:193)
~[apache-cassandra-3.11.11.jar:3.11.11]
at
org.apache.cassandra.net.OutboundTcpConnectionPool.getConnection(OutboundTcpConnectionPool.java:76)
~[apache-cassandra-3.11.11.jar:3.11.11]
at
org.apache.cassandra.net.MessagingService.getConnection(MessagingService.java:802)
~[apache-cassandra-3.11.11.jar:3.11.11]
at
org.apache.cassandra.net.MessagingService.sendOneWay(MessagingService.java:953)
~[apache-cassandra-3.11.11.jar:3.11.11]
at
org.apache.cassandra.net.MessagingService.sendRR(MessagingService.java:895)
~[apache-cassandra-3.11.11.jar:3.11.11]
at
org.apache.cassandra.net.MessagingService.sendRRWithFailure(MessagingService.java:877)
~[apache-cassandra-3.11.11.jar:3.11.11]
at
org.apache.cassandra.service.AbstractReadExecutor.makeRequests(AbstractReadExecutor.java:110)
~[apache-cassandra-3.11.11.jar:3.11.11]
at
org.apache.cassandra.service.AbstractReadExecutor.makeDataRequests(AbstractReadExecutor.java:85)
~[apache-cassandra-3.11.11.jar:3.11.11]
at
org.apache.cassandra.service.AbstractReadExecutor$NeverSpeculatingReadExecutor.executeAsync(AbstractReadExecutor.java:220)
~[apache-cassandra-3.11.11.jar:3.11.11]
at
org.apache.cassandra.service.StorageProxy$SinglePartitionReadLifecycle.doInitialQueries(StorageProxy.java:1907)
~[apache-cassandra-3.11.11.jar:3.11.11]
at
org.apache.cassandra.service.StorageProxy.fetchRows(StorageProxy.java:1860)
~[apache-cassandra-3.11.11.jar:3.11.11]
at
org.apache.cassandra.service.StorageProxy.readRegular(StorageProxy.java:1800)
~[apache-cassandra-3.11.11.jar:3.11.11]
at
org.apache.cassandra.service.StorageProxy.read(StorageProxy.java:1705)
~[apache-cassandra-3.11.11.jar:3.11.11]
at
org.apache.cassandra.thrift.CassandraServer.read(CassandraServer.java:98)
~[apache-cassandra-3.11.11.jar:3.11.11]
at
org.apache.cassandra.thrift.CassandraServer.getSlice(CassandraServer.java:265)
~[apache-cassandra-3.11.11.jar:3.11.11]
at
org.apache.cassandra.thrift.CassandraServer.multigetSliceInternal(CassandraServer.java:590)
~[apache-cassandra-3.11.11.jar:3.11.11]
at
org.apache.cassandra.thrift.CassandraServer.getSliceInternal(CassandraServer.java:325)
~[apache-cassandra-3.11.11.jar:3.11.11]
at
org.apache.cassandra.thrift.CassandraServer.get_slice(CassandraServer.java:302)
~[apache-cassandra-3.11.11.jar:3.11.11]
at
org.apache.cassandra.thrift.Cassandra$Processor$get_slice.getResult(Cassandra.java:3659)
~[apache-cassandra-thrift-3.11.11.jar:3.11.11]
at
org.apache.cassandra.thrift.Cassandra$Processor$get_slice.getResult(Cassandra.java:3643)
~[apache-cassandra-thrift-3.11.11.jar:3.11.11]
at org.apache.thrift.ProcessFunction.process(ProcessFunction.java:39)
~[libthrift-0.9.2.jar:0.9.2]
at org.apache.thrift.TBaseProcessor.process(TBaseProcessor.java:39)
~[libthrift-0.9.2.jar:0.9.2]
at
org.apache.cassandra.thrift.CustomTThreadPoolServer$WorkerProcess.run(CustomTThreadPoolServer.java:206)
~[apache-cassandra-3.11.11.jar:3.11.11]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
[na:1.8.0_322]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
[na:1.8.0_322]
at
org.apache.cassandra.concurrent.NamedThreadFactory.lambda$threadLocalDeallocator$0(NamedThreadFactory.java:84)
[apache-cassandra-3.11.11.jar:3.11.11]
at java.lang.Thread.run(Thread.java:750) ~[na:1.8.0_322] {code}
Table definition:
{code:java}
CfDef cfd = new CfDef(keyspaceName, tableName)
.setColumn_type(ColumnType.SUPER.getValue())
.setKey_validation_class("UTF8Type")
.setComparator_type("UTF8Type")
.setSubcomparator_type("UTF8Type")
.setDefault_validation_class("UTF8Type");
{code}
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
