From 60ba5263bb01a39557b63a38a74140fbe6bb5ac4 Mon Sep 17 00:00:00 2001
From: LoggingResearch <139747524+LoggingResearch@users.noreply.github.com>
Date: Sat, 22 Jul 2023 16:17:24 +0800
Subject: [PATCH] Unhandled InterruptedException and missing log in
 Supervisor's close() method

---
 .../java/org/apache/storm/daemon/supervisor/Supervisor.java     | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/storm-server/src/main/java/org/apache/storm/daemon/supervisor/Supervisor.java b/storm-server/src/main/java/org/apache/storm/daemon/supervisor/Supervisor.java
index 978cc9b9437..c432799a4f1 100644
--- a/storm-server/src/main/java/org/apache/storm/daemon/supervisor/Supervisor.java
+++ b/storm-server/src/main/java/org/apache/storm/daemon/supervisor/Supervisor.java
@@ -524,6 +524,8 @@ void killWorkers(Collection<String> workerIds, ContainerLauncher launcher) throw
                 } else {
                     k.cleanUp();
                 }
+            } catch (InterruptedException e) {
+                LOG.error("Error closing asyncLocalizer", e);
             } catch (Exception e) {
                 LOG.error("Error trying to kill {}", workerId, e);
             }