Fix flaky DiskSpaceMetricsTest

Author: blambov

test/unit/org/apache/cassandra/io/DiskSpaceMetricsTest.java

@@ -99,15 +99,15 @@ public void summaryRedistribution() throws Throwable
     @Test
     public void testFlushSize() throws Throwable
     {
-        createTable("CREATE TABLE %s (pk bigint, PRIMARY KEY (pk))");
-        ColumnFamilyStore cfs = getCurrentColumnFamilyStore();
+        createTable(KEYSPACE_PER_TEST, "CREATE TABLE %s (pk bigint, PRIMARY KEY (pk))");
+        ColumnFamilyStore cfs = getCurrentColumnFamilyStore(KEYSPACE_PER_TEST);
         assertTrue(Double.isNaN(cfs.metric.flushSizeOnDisk.get()));
 
         // disable compaction so nothing changes between calculations
         cfs.disableAutoCompaction();
 
         for (int i = 0; i < 3; i++)
-            insertN(cfs, 1000, 55);
+            insertN(KEYSPACE_PER_TEST, cfs, 1000, 55);
 
         int totalSize = 0;
         final Set<SSTableReader> liveSSTables = cfs.getLiveSSTables();
@@ -125,9 +125,14 @@ private void insert(ColumnFamilyStore cfs, long value) throws Throwable
     }
 
     private void insertN(ColumnFamilyStore cfs, int n, long base) throws Throwable
+    {
+        insertN(KEYSPACE, cfs, n, base);
+    }
+
+    private void insertN(String keyspace, ColumnFamilyStore cfs, int n, long base) throws Throwable
     {
         for (int i = 0; i < n; i++)
-            execute("INSERT INTO %s (pk) VALUES (?)", base + i);
+            executeFormattedQuery(formatQuery(keyspace, "INSERT INTO %s (pk) VALUES (?)"), base + i);
 
         // flush to write the sstable
         Util.flush(cfs);