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

DBZ-1101 Increase wait times for shutdown

Browse Source
This commit is contained in:
Jiri Pechanec 2019-01-25 11:21:30 +01:00 committed by Gunnar Morling
parent 52c2cf07dd
commit 80334ea14a
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
debezium-embedded/src/test/java/io/debezium/embedded/AbstractConnectorTest.java
View File

@ -133,6 +133,7 @@ public void stopConnector(BooleanConsumer callback) {
// Oracle connector needs longer time to complete shutdown
engine.await(60, TimeUnit.SECONDS);
} catch (InterruptedException e) {
logger.warn("Engine has not stopped on time");
Thread.interrupted();
}
}
@ -140,19 +141,21 @@ public void stopConnector(BooleanConsumer callback) {
List<Runnable> neverRunTasks = executor.shutdownNow();
assertThat(neverRunTasks).isEmpty();
try {
while (!executor.awaitTermination(10, TimeUnit.SECONDS)) {
while (!executor.awaitTermination(60, TimeUnit.SECONDS)) {
// wait for completion ...
}
} catch (InterruptedException e) {
logger.warn("Executor has not stopped on time");
Thread.interrupted();
}
}
if (engine != null && engine.isRunning()) {
try {
while (!engine.await(5, TimeUnit.SECONDS)) {
while (!engine.await(60, TimeUnit.SECONDS)) {
// Wait for connector to stop completely ...
}
} catch (InterruptedException e) {
logger.warn("Connector has not stopped on time");
Thread.interrupted();
}
}