diff --git a/src/java/org/apache/cassandra/cql/QueryProcessor.java b/src/java/org/apache/cassandra/cql/QueryProcessor.java index 4af765e14a..b0b8e4e369 100644 --- a/src/java/org/apache/cassandra/cql/QueryProcessor.java +++ b/src/java/org/apache/cassandra/cql/QueryProcessor.java @@ -605,8 +605,9 @@ public class QueryProcessor { for (Term column : delete.getColumns()) { - validateColumnName(keyspace, delete.getColumnFamily(), column.getByteBuffer(comparator)); - rm.delete(new QueryPath(delete.getColumnFamily(), null, column.getByteBuffer(comparator)), + ByteBuffer columnName = column.getByteBuffer(comparator); + validateColumnName(keyspace, delete.getColumnFamily(), columnName); + rm.delete(new QueryPath(delete.getColumnFamily(), null, columnName), System.currentTimeMillis()); } }