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;
     }

Reply via email to