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

DBZ-1103 Make pause before interrupt configurable

Browse Source
This commit is contained in:
Jiri Pechanec 2019-01-28 10:44:32 +01:00 committed by Gunnar Morling
parent ccff79e07d
commit 32f9543979
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
debezium-embedded/src/main/java/io/debezium/embedded/EmbeddedEngine.java
View File

@ -183,7 +183,8 @@ public final class EmbeddedEngine implements Runnable {
OFFSET_FLUSH_INTERVAL_MS, OFFSET_COMMIT_TIMEOUT_MS,
INTERNAL_KEY_CONVERTER_CLASS, INTERNAL_VALUE_CONVERTER_CLASS);
private static final int WAIT_FOR_COMPLETION_BEFORE_INTERRUPT = 2;
private static final Duration WAIT_FOR_COMPLETION_BEFORE_INTERRUPT_DEFAULT = Duration.ofSeconds(2);
private static final String WAIT_FOR_COMPLETION_BEFORE_INTERRUPT_PROP = "debezium.embedded.shutdown.pause.before.interrupt.ms";
/**
* A callback function to be notified when the connector completes.
@ -989,7 +990,7 @@ public boolean stop() {
Thread thread = this.runningThread.getAndSet(null);
if (thread != null) {
try {
latch.await(WAIT_FOR_COMPLETION_BEFORE_INTERRUPT, TimeUnit.SECONDS);
latch.await(Integer.parseInt(System.getProperty(WAIT_FOR_COMPLETION_BEFORE_INTERRUPT_PROP, Long.toString(WAIT_FOR_COMPLETION_BEFORE_INTERRUPT_DEFAULT.toMillis()))), TimeUnit.MILLISECONDS);
}
catch (InterruptedException e) {
}