From fa8e10040f5234340ab4766160a754943847345e Mon Sep 17 00:00:00 2001
From: Steve Hawkins <shawkins@redhat.com>
Date: Sun, 30 Jan 2022 12:16:43 -0500
Subject: [PATCH] adding missing flushes

---
 .../kubernetes/client/dsl/internal/ExecWebSocketListener.java   | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/kubernetes-client/src/main/java/io/fabric8/kubernetes/client/dsl/internal/ExecWebSocketListener.java b/kubernetes-client/src/main/java/io/fabric8/kubernetes/client/dsl/internal/ExecWebSocketListener.java
index 745d64f08af..d035f332c16 100644
--- a/kubernetes-client/src/main/java/io/fabric8/kubernetes/client/dsl/internal/ExecWebSocketListener.java
+++ b/kubernetes-client/src/main/java/io/fabric8/kubernetes/client/dsl/internal/ExecWebSocketListener.java
@@ -242,11 +242,13 @@ public void onMessage(WebSocket webSocket, ByteBuffer bytes) {
                     case 2:
                         if (err != null) {
                           Channels.newChannel(err).write(byteString);
+                          err.flush();
                         }
                         break;
                     case 3:
                         if (errChannel != null) {
                           Channels.newChannel(errChannel).write(byteString);
+                          errChannel.flush();
                         }
                         break;
                     default: