You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by bl...@apache.org on 2020/05/29 09:26:47 UTC

[cassandra] branch trunk updated: Fix CassandraStreamManagerTest.incrementalSSTableSelection flakiness

This is an automated email from the ASF dual-hosted git repository.

blerer pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/cassandra.git


The following commit(s) were added to refs/heads/trunk by this push:
     new bcc1174  Fix CassandraStreamManagerTest.incrementalSSTableSelection flakiness
bcc1174 is described below

commit bcc1174e9bba9ba0cacbc9356d48a7599c50e03e
Author: Bereng <be...@gmail.com>
AuthorDate: Wed May 27 12:27:10 2020 +0200

    Fix CassandraStreamManagerTest.incrementalSSTableSelection flakiness
    
    patch by Berenguer Blasi; reviewed by Benjamin Lerer for CASSANDRA-15825
    
    The flakiness was caused by automatic compactions that were triggered by
    the creation of the fourth SStable.
---
 .../org/apache/cassandra/db/streaming/CassandraStreamManagerTest.java  | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/test/unit/org/apache/cassandra/db/streaming/CassandraStreamManagerTest.java b/test/unit/org/apache/cassandra/db/streaming/CassandraStreamManagerTest.java
index ae3ff92..0b37d66 100644
--- a/test/unit/org/apache/cassandra/db/streaming/CassandraStreamManagerTest.java
+++ b/test/unit/org/apache/cassandra/db/streaming/CassandraStreamManagerTest.java
@@ -161,6 +161,9 @@ public class CassandraStreamManagerTest
     @Test
     public void incrementalSSTableSelection() throws Exception
     {
+        // CASSANDRA-15825 Make sure a compaction won't be triggered under our feet removing the sstables mid-flight
+        cfs.disableAutoCompaction();
+
         // make 3 tables, 1 unrepaired, 2 pending repair with different repair ids, and 1 repaired
         SSTableReader sstable1 = createSSTable(() -> QueryProcessor.executeInternal(String.format("INSERT INTO %s.%s (k, v) VALUES (1, 1)", keyspace, table)));
         SSTableReader sstable2 = createSSTable(() -> QueryProcessor.executeInternal(String.format("INSERT INTO %s.%s (k, v) VALUES (2, 2)", keyspace, table)));


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@cassandra.apache.org
For additional commands, e-mail: commits-help@cassandra.apache.org