[CASSANDRA-10739] Timeout for CQL Deletes on an Entire Partition Against Specified Columns

• Type: Bug
• Status: Resolved
• Priority: Normal
• Resolution: Fixed
• Fix Version/s: 3.0.1, 3.1
• Component/s: Legacy/CQL, Legacy/Local Write-Read Paths
• Severity: Normal
• Assignee: Benjamin Lerer
• Reporter: Caleb Rackliffe

Authors

Benjamin Lerer

Reviewers

Carl Yeksigian

• Created: 19/Nov/15 21:07
• Updated: 16/Apr/19 09:30
• Resolved: 01/Dec/15 17:17

Description

cqlsh:graphs> delete color from composite_pk where k1 = '1' and k2 = '1';
cqlsh:graphs> create table composite_with_clustering(k1 text, k2 text, c1 text, color text, value float, primary key ((k1, k2), c1));
cqlsh:graphs> insert into composite_with_clustering(k1, k2, c1, value) values ('1','1', '1', 6);
cqlsh:graphs> insert into composite_with_clustering(k1, k2, c1, color) values ('1','1', '2', 'green');
cqlsh:graphs> delete color from composite_with_clustering where k1 = '1' and k2 = '1';
WriteTimeout: code=1100 [Coordinator node timed out waiting for replica nodes' responses] message="Operation timed out - received only 0 responses." info={'received_responses': 0, 'required_responses': 1, 'consistency': 'ONE'}

Clustering$Serializer clearly doesn't like this:

WARN  [SharedPool-Worker-2] 2015-11-19 20:55:15,935  AbstractTracingAwareExecutorService.java:169 - Uncaught exception on thread Thread[SharedPool-Worker-2,5,main]: {}
java.lang.AssertionError: Invalid clustering for the table: org.apache.cassandra.db.Clustering$2@3157dded
	at org.apache.cassandra.db.Clustering$Serializer.serialize(Clustering.java:136) ~[cassandra-all-3.0.0.710.jar:3.0.0.710]
	at org.apache.cassandra.db.rows.UnfilteredSerializer.serialize(UnfilteredSerializer.java:159) ~[cassandra-all-3.0.0.710.jar:3.0.0.710]
	at org.apache.cassandra.db.rows.UnfilteredSerializer.serialize(UnfilteredSerializer.java:108) ~[cassandra-all-3.0.0.710.jar:3.0.0.710]
	at org.apache.cassandra.db.rows.UnfilteredSerializer.serialize(UnfilteredSerializer.java:96) ~[cassandra-all-3.0.0.710.jar:3.0.0.710]
	at org.apache.cassandra.db.rows.UnfilteredRowIteratorSerializer.serialize(UnfilteredRowIteratorSerializer.java:132) ~[cassandra-all-3.0.0.710.jar:3.0.0.710]
	at org.apache.cassandra.db.rows.UnfilteredRowIteratorSerializer.serialize(UnfilteredRowIteratorSerializer.java:87) ~[cassandra-all-3.0.0.710.jar:3.0.0.710]
	at org.apache.cassandra.db.partitions.PartitionUpdate$PartitionUpdateSerializer.serialize(PartitionUpdate.java:599) ~[cassandra-all-3.0.0.710.jar:3.0.0.710]
	at org.apache.cassandra.db.Mutation$MutationSerializer.serialize(Mutation.java:291) ~[cassandra-all-3.0.0.710.jar:3.0.0.710]
	at org.apache.cassandra.db.commitlog.CommitLog.add(CommitLog.java:279) ~[cassandra-all-3.0.0.710.jar:3.0.0.710]

If this isn't supported, there should probably be a more obvious error message.