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: