diff --git a/CHANGES.txt b/CHANGES.txt index b77844470a..e922635514 100644 --- a/CHANGES.txt +++ b/CHANGES.txt @@ -1,3 +1,7 @@ +2.1.17 + * Don't skip sstables based on maxLocalDeletionTime (CASSANDRA-12765) + + 2.1.16 * Avoid infinitely looping result set when paging SELECT queries with an IN clause with duplicate keys by treating the IN values as a set instead diff --git a/src/java/org/apache/cassandra/db/CollationController.java b/src/java/org/apache/cassandra/db/CollationController.java index 8a966bca6d..0f2674eee9 100644 --- a/src/java/org/apache/cassandra/db/CollationController.java +++ b/src/java/org/apache/cassandra/db/CollationController.java @@ -258,13 +258,9 @@ public class CollationController if (!filter.shouldInclude(sstable)) { nonIntersectingSSTables++; - // sstable contains no tombstone if maxLocalDeletionTime == Integer.MAX_VALUE, so we can safely skip those entirely - if (sstable.getSSTableMetadata().maxLocalDeletionTime != Integer.MAX_VALUE) - { - if (skippedSSTables == null) - skippedSSTables = new ArrayList<>(); - skippedSSTables.add(sstable); - } + if (skippedSSTables == null) + skippedSSTables = new ArrayList<>(); + skippedSSTables.add(sstable); continue; } diff --git a/test/unit/org/apache/cassandra/db/CollationControllerCQLTest.java b/test/unit/org/apache/cassandra/db/CollationControllerCQLTest.java new file mode 100644 index 0000000000..376678a73d --- /dev/null +++ b/test/unit/org/apache/cassandra/db/CollationControllerCQLTest.java @@ -0,0 +1,46 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +package org.apache.cassandra.db; + +import org.junit.Test; + +import org.apache.cassandra.cql3.CQLTester; +import org.apache.cassandra.cql3.UntypedResultSet; +import static org.junit.Assert.assertTrue; + +public class CollationControllerCQLTest extends CQLTester +{ + @Test + public void partitionLevelDeletionTest() throws Throwable + { + createTable("CREATE TABLE %s (bucket_id TEXT,name TEXT,data TEXT,PRIMARY KEY (bucket_id, name))"); + execute("insert into %s (bucket_id, name, data) values ('8772618c9009cf8f5a5e0c18', 'test', 'hello')"); + getCurrentColumnFamilyStore().forceBlockingFlush(); + execute("insert into %s (bucket_id, name, data) values ('8772618c9009cf8f5a5e0c19', 'test2', 'hello');"); + execute("delete from %s where bucket_id = '8772618c9009cf8f5a5e0c18'"); + getCurrentColumnFamilyStore().forceBlockingFlush(); + UntypedResultSet res = execute("select * from %s where bucket_id = '8772618c9009cf8f5a5e0c18' and name = 'test'"); + assertTrue(res.isEmpty()); + } + + private ColumnFamilyStore getCurrentColumnFamilyStore() + { + return Keyspace.open(KEYSPACE).getColumnFamilyStore(currentTable()); + } +}