diff --git a/test/unit/org/apache/cassandra/db/commitlog/CommitLogCQLTest.java b/test/unit/org/apache/cassandra/db/commitlog/CommitLogCQLTest.java index 2fd38d8e8c..90f9627af6 100644 --- a/test/unit/org/apache/cassandra/db/commitlog/CommitLogCQLTest.java +++ b/test/unit/org/apache/cassandra/db/commitlog/CommitLogCQLTest.java @@ -32,6 +32,7 @@ import org.junit.Test; import org.apache.cassandra.cql3.CQLTester; import org.apache.cassandra.cql3.QueryProcessor; import org.apache.cassandra.db.ColumnFamilyStore; +import org.apache.cassandra.utils.FBUtilities; public class CommitLogCQLTest extends CQLTester { @@ -89,7 +90,7 @@ public class CommitLogCQLTest extends CQLTester { QueryProcessor.executeInternal(stmt, i, Integer.toString(i)); } - cfs.dumpMemtable(); + FBUtilities.waitOnFuture(cfs.dumpMemtable()); } } catch (Throwable t)