alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-1419 Fix timing issue waiting for streaming to start

Browse Source
This commit is contained in:
Chris Cranford 2019-08-20 11:04:04 -04:00 committed by Gunnar Morling
parent c6f6020da5
commit ef30b8a8cf
1 changed files with 2 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
debezium-connector-postgres/src/test/java/io/debezium/connector/postgresql/RecordsStreamProducerIT.java
View File

@ -181,10 +181,7 @@ public void shouldReceiveChangesAfterConnectionRestart() throws Exception {
TestHelper.execute("CREATE TABLE t0 (pk SERIAL, d INTEGER, PRIMARY KEY(pk));");
consumer = testConsumer(1);
// Start the producer and wait; the wait is to guarantee that the stream thread is polling
// This appears to be a potential race condition problem
TimeUnit.SECONDS.sleep(TestHelper.waitTimeForRecords());
waitForStreamingToStart();
// Insert new row and verify inserted
executeAndWait("INSERT INTO t0 (pk,d) VALUES(1,1);");
@ -206,7 +203,7 @@ public void shouldReceiveChangesAfterConnectionRestart() throws Exception {
false
);
consumer = testConsumer(1);
TimeUnit.SECONDS.sleep(TestHelper.waitTimeForRecords());
waitForStreamingToStart();
// Insert new row and verify inserted
executeAndWait("INSERT INTO t0 (pk,d,d2) VALUES (2,1,3);");