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 2024/01/10 07:49:30 UTC

(camel) 01/02: CAMEL-20297 camel-aws2-athena: do not swallow interrupted exceptions

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 <an...@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;
     }