fix: catching rejected execution

closes: #6747

Signed-off-by: Steve Hawkins <[email protected]>

CHANGELOG.md

@@ -4,6 +4,8 @@
 
 #### Bugs
 
+* Fix #6747: Preventing websocket error logs when the client is closed
+
 #### Improvements
 
 #### Dependency Upgrade

kubernetes-client/src/main/java/io/fabric8/kubernetes/client/dsl/internal/ExecWebSocketListener.java

@@ -47,6 +47,7 @@
 import java.util.concurrent.Executor;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
+import java.util.concurrent.RejectedExecutionException;
 import java.util.concurrent.atomic.AtomicBoolean;
 import java.util.concurrent.atomic.AtomicReference;
 
@@ -370,19 +371,23 @@ public void onClose(WebSocket webSocket, int code, String reason) {
     }
     closeWebSocketOnce(code, reason);
     LOGGER.debug("Exec Web Socket: On Close with code:[{}], due to: [{}]", code, reason);
-    serialExecutor.execute(() -> {
-      try {
-        if (exitCode.complete(null)) {
-          // this is expected for processes that don't terminate - uploads for example
-          LOGGER.debug("Exec Web Socket: completed with a null exit code - no status was received prior to onClose");
-        }
-        cleanUpOnce();
-      } finally {
-        if (listener != null) {
-          listener.onClose(code, reason);
+    try {
+      serialExecutor.execute(() -> {
+        try {
+          if (exitCode.complete(null)) {
+            // this is expected for processes that don't terminate - uploads for example
+            LOGGER.debug("Exec Web Socket: completed with a null exit code - no status was received prior to onClose");
+          }
+          cleanUpOnce();
+        } finally {
+          if (listener != null) {
+            listener.onClose(code, reason);
+          }
         }
-      }
-    });
+      });
+    } catch (RejectedExecutionException e) {
+      LOGGER.debug("Client already shutdown, aborting normal closure", e);
+    }
   }
 
   @Override