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

DBZ-1103 Wait for completion before interrupt

Browse Source
This commit is contained in:
Jiri Pechanec 2019-01-25 13:20:21 +01:00 committed by Gunnar Morling
parent 80334ea14a
commit 3bd97d3bd7
1 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -183,6 +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;
/**
* A callback function to be notified when the connector completes.
*/
@ -986,6 +988,11 @@ public boolean stop() {
// Signal that the run() method should stop ...
Thread thread = this.runningThread.getAndSet(null);
if (thread != null) {
try {
latch.await(WAIT_FOR_COMPLETION_BEFORE_INTERRUPT, TimeUnit.SECONDS);
}
catch (InterruptedException e) {
}
logger.debug("Interruping the embedded engine's thread " + thread + " (already interrupted: " + thread.isInterrupted() + ")");
// Interrupt the thread in case it is blocked while polling the task for records ...
thread.interrupt();