DBZ-1764 Reorg test code for stabilization
This commit is contained in:
parent
92fa6039ab
commit
c512929097
@ -101,15 +101,15 @@ public void shouldProcessFromStreaming() throws Exception {
|
||||
|
||||
Testing.Print.enable();
|
||||
TestHelper.enableTableCdc(connection, "t1");
|
||||
waitForEnabledCdc(connection, "t1");
|
||||
connection.execute("INSERT INTO t1 VALUES (1,10);");
|
||||
|
||||
TestHelper.enableTableCdc(connection, "t2");
|
||||
waitForEnabledCdc(connection, "t2");
|
||||
connection.execute("INSERT INTO t2 VALUES (2,20);");
|
||||
|
||||
TestHelper.enableTableCdc(connection, "t3");
|
||||
|
||||
waitForEnabledCdc(connection, "t1");
|
||||
waitForEnabledCdc(connection, "t2");
|
||||
waitForEnabledCdc(connection, "t3");
|
||||
|
||||
connection.execute("INSERT INTO t1 VALUES (1,10);");
|
||||
connection.execute("INSERT INTO t2 VALUES (2,20);");
|
||||
connection.execute("INSERT INTO t3 VALUES (3,30);");
|
||||
|
||||
final int expectedRecordsCount = 1 + 1 + 1;
|
||||
|
Loading…
Reference in New Issue
Block a user