Use explicit timestamp to avoid getting sstables in different windows Patch by marcuse; reviewed by yukim for CASSANDRA-12825
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/e5a5fb96 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/e5a5fb96 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/e5a5fb96 Branch: refs/heads/cassandra-3.11 Commit: e5a5fb96c3cc19ceeb3ad9303dc1db7b1b506a1f Parents: 5978f9d Author: Marcus Eriksson <marc...@apache.org> Authored: Wed Nov 9 08:55:55 2016 +0100 Committer: Marcus Eriksson <marc...@apache.org> Committed: Mon Apr 3 08:32:13 2017 +0200 ---------------------------------------------------------------------- .../org/apache/cassandra/db/compaction/CompactionsCQLTest.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/e5a5fb96/test/unit/org/apache/cassandra/db/compaction/CompactionsCQLTest.java ---------------------------------------------------------------------- diff --git a/test/unit/org/apache/cassandra/db/compaction/CompactionsCQLTest.java b/test/unit/org/apache/cassandra/db/compaction/CompactionsCQLTest.java index aa29808..1d77b17 100644 --- a/test/unit/org/apache/cassandra/db/compaction/CompactionsCQLTest.java +++ b/test/unit/org/apache/cassandra/db/compaction/CompactionsCQLTest.java @@ -64,9 +64,9 @@ public class CompactionsCQLTest extends CQLTester { createTable("CREATE TABLE %s (id text PRIMARY KEY) WITH compaction = {'class':'DateTieredCompactionStrategy', 'min_threshold':2};"); assertTrue(getCurrentColumnFamilyStore().getCompactionStrategy().isEnabled()); - execute("insert into %s (id) values ('1')"); + execute("insert into %s (id) values ('1') using timestamp 1000"); // same timestamp = same window = minor compaction triggered flush(); - execute("insert into %s (id) values ('1')"); + execute("insert into %s (id) values ('1') using timestamp 1000"); flush(); waitForMinor(KEYSPACE, currentTable(), 5000, true); }