You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by or...@apache.org on 2021/01/14 12:26:26 UTC
[camel-kafka-connector] 09/14: Add an warning if the embedded
runner times out before fully stopped
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit 99214cfb4c991be516191df93080a10269f6ae99
Author: Otavio Rodolfo Piske <op...@redhat.com>
AuthorDate: Wed Jan 13 15:18:07 2021 +0100
Add an warning if the embedded runner times out before fully stopped
---
.../common/services/kafkaconnect/KafkaConnectRunnerService.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git a/tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/services/kafkaconnect/KafkaConnectRunnerService.java b/tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/services/kafkaconnect/KafkaConnectRunnerService.java
index c895490..4c623a6 100644
--- a/tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/services/kafkaconnect/KafkaConnectRunnerService.java
+++ b/tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/services/kafkaconnect/KafkaConnectRunnerService.java
@@ -96,7 +96,9 @@ public class KafkaConnectRunnerService implements KafkaConnectService {
public void stop() {
kafkaConnectRunner.stop();
try {
- service.awaitTermination(5, TimeUnit.SECONDS);
+ if (!service.awaitTermination(5, TimeUnit.SECONDS)) {
+ LOG.warn("Timed out while waiting for the embedded runner to stop");
+ }
} catch (InterruptedException e) {
LOG.warn("The test was interrupted while executing");
}