DBZ-1763 minor change.
This commit is contained in:
parent
d8f330ebbd
commit
3c68eac422
@ -31,8 +31,7 @@ public void testProcess() throws Exception {
|
|||||||
context.getCassandraClient().execute("CREATE TABLE IF NOT EXISTS " + keyspaceTable("table1") + " (a int, b text, PRIMARY KEY(a)) WITH cdc = false;");
|
context.getCassandraClient().execute("CREATE TABLE IF NOT EXISTS " + keyspaceTable("table1") + " (a int, b text, PRIMARY KEY(a)) WITH cdc = false;");
|
||||||
schemaProcessor.process();
|
schemaProcessor.process();
|
||||||
assertEquals(0, context.getSchemaHolder().getCdcEnabledTableMetadataSet().size());
|
assertEquals(0, context.getSchemaHolder().getCdcEnabledTableMetadataSet().size());
|
||||||
keyValueSchema = context.getSchemaHolder().getOrUpdateKeyValueSchema(new KeyspaceTable(TEST_KEYSPACE, "table1"));
|
assertNull(context.getSchemaHolder().getOrUpdateKeyValueSchema(new KeyspaceTable(TEST_KEYSPACE, "table1")));
|
||||||
assertNull(keyValueSchema);
|
|
||||||
|
|
||||||
context.getCassandraClient().execute("ALTER TABLE " + keyspaceTable("table1") + " WITH cdc = true;");
|
context.getCassandraClient().execute("ALTER TABLE " + keyspaceTable("table1") + " WITH cdc = true;");
|
||||||
schemaProcessor.process();
|
schemaProcessor.process();
|
||||||
|
Loading…
Reference in New Issue
Block a user