From c3e2980bd4efa526fd9e47b74c50c5c009dc3317 Mon Sep 17 00:00:00 2001
From: Monishkumar Gajendran <monishku@amazon.com>
Date: Wed, 6 Oct 2021 17:29:34 -0700
Subject: [PATCH] Fix setting interrupot status after shutdown

---
 .../kinesis/retrieval/polling/PrefetchRecordsPublisher.java   | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/polling/PrefetchRecordsPublisher.java b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/polling/PrefetchRecordsPublisher.java
index 233d9fd5..c1f6bc80 100644
--- a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/polling/PrefetchRecordsPublisher.java
+++ b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/polling/PrefetchRecordsPublisher.java
@@ -306,10 +306,10 @@ public class PrefetchRecordsPublisher implements RecordsPublisher {
                 }
             }
         } catch (InterruptedException e) {
-            // Preserve interrupt status
-            Thread.currentThread().interrupt();
             // (Re-)Cancel if current thread also interrupted
             executorService.shutdownNow();
+            // Preserve interrupt status
+            Thread.currentThread().interrupt();
         }
         started = false;
     }