From 32c2c8a33f195fb76b9f1d7d72d3bdc4ed6495cf Mon Sep 17 00:00:00 2001
From: Hoan Nguyen <nguyenanhhoan@gmail.com>
Date: Mon, 8 Nov 2021 16:35:25 -0800
Subject: [PATCH] Add Thread.currentThread().interrupt() to fix bug

---
 .../processinglibrary/AWSCloudTrailProcessingExecutor.java       | 1 +
 1 file changed, 1 insertion(+)

diff --git a/aws-cloudtrail-processing-library-master/src/main/java/com/amazonaws/services/cloudtrail/processinglibrary/AWSCloudTrailProcessingExecutor.java b/aws-cloudtrail-processing-library-master/src/main/java/com/amazonaws/services/cloudtrail/processinglibrary/AWSCloudTrailProcessingExecutor.java
index 6af70600a..904609c4d 100644
--- a/aws-cloudtrail-processing-library-master/src/main/java/com/amazonaws/services/cloudtrail/processinglibrary/AWSCloudTrailProcessingExecutor.java
+++ b/aws-cloudtrail-processing-library-master/src/main/java/com/amazonaws/services/cloudtrail/processinglibrary/AWSCloudTrailProcessingExecutor.java
@@ -142,6 +142,7 @@ private void stopThreadPool(ExecutorService threadPool) {
                 threadPool.awaitTermination(config.getThreadTerminationDelaySeconds(), TimeUnit.SECONDS);
             } catch (InterruptedException e) {
                 logger.debug("Wait thread pool termination is interrupted.");
+                Thread.currentThread().interrupt();
             }
 
             if (!threadPool.isShutdown()) { // ShutdownNow after waiting