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

DBZ-3577 Fix race condition in shouldFailOnSchemaInconsistency test

Browse Source
This commit is contained in:
Kate 2021-07-27 15:34:27 -04:00 committed by Jiri Pechanec
parent 9b66ab374a
commit 6a30ad3811
1 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
debezium-connector-mysql/src/test/java/io/debezium/connector/mysql/StreamingSourceIT.java
View File

@ -558,10 +558,18 @@ private void inconsistentSchema(EventProcessingFailureHandlingMode mode) throws
final JdbcConnection connection = db.connect();
final Connection jdbc = connection.connection();
final Statement statement = jdbc.createStatement()) {
if (mode == null) {
waitForStreamingRunning("mysql", DATABASE.getServerName(), "streaming");
}
statement.executeUpdate("INSERT INTO customers VALUES (default,'John','Lazy','john.lazy@acme.com')");
}
waitForStreamingRunning("mysql", DATABASE.getServerName(), "streaming");
if (mode == null) {
waitForConnectorShutdown("mysql", DATABASE.getServerName());
}
else {
waitForStreamingRunning("mysql", DATABASE.getServerName(), "streaming");
}
stopConnector();
final Throwable e = exception.get();
if (e != null) {