bdeggleston commented on code in PR #4708:
URL: https://github.com/apache/cassandra/pull/4708#discussion_r3562173037
##########
test/unit/org/apache/cassandra/db/virtual/MutationJournalTableTest.java:
##########
@@ -50,21 +50,25 @@ public static void setUpClass()
@Before
public void setUp()
{
- schemaChange("CREATE TABLE " + KEYSPACE + ".tbl(pk int PRIMARY KEY, v
int)");
+ schemaChange("CREATE KEYSPACE ks WITH
replication={'class':'SimpleStrategy', 'replication_factor':1} AND
replication_type='tracked'");
+ schemaChange("CREATE TABLE ks.tbl(pk int PRIMARY KEY, v int)");
}
@Test
public void testSelectAll() throws Throwable
{
// Start the mutation journal
MutationJournal.start();
+ enableCoordinatorExecution();
// Write data to trigger journal writes
for (int i = 0; i < 100; i++)
{
- execute("INSERT INTO " + KEYSPACE + ".tbl(pk, v) VALUES (?, ?)",
i, i);
+ execute("INSERT INTO ks.tbl(pk, v) VALUES (?, ?)", i, i);
}
+ Thread.sleep(15000);
Review Comment:
I don't think so, removed
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
