This is an automated email from the ASF dual-hosted git repository. orpiske pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel.git
commit 9e173007798562e3d4180a74ab416ad288de83d5 Author: Otavio Rodolfo Piske <angusyo...@gmail.com> AuthorDate: Tue Jan 9 14:32:24 2024 +0100 CAMEL-20297 camel-aws2-athena: do not swallow interrupted exceptions --- .../java/org/apache/camel/component/aws2/athena/Athena2QueryHelper.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/components/camel-aws/camel-aws2-athena/src/main/java/org/apache/camel/component/aws2/athena/Athena2QueryHelper.java b/components/camel-aws/camel-aws2-athena/src/main/java/org/apache/camel/component/aws2/athena/Athena2QueryHelper.java index 5580e3fde00..97fe349a05d 100644 --- a/components/camel-aws/camel-aws2-athena/src/main/java/org/apache/camel/component/aws2/athena/Athena2QueryHelper.java +++ b/components/camel-aws/camel-aws2-athena/src/main/java/org/apache/camel/component/aws2/athena/Athena2QueryHelper.java @@ -168,6 +168,8 @@ class Athena2QueryHelper { this.interrupted = Thread.interrupted(); // store, then clear, interrupt status LOG.trace( "AWS Athena start query execution wait thread was interrupted; will return at earliest opportunity"); + + Thread.currentThread().interrupt(); } this.currentDelay = this.delay; }