Resolved the issue #2358

kubernetes/base/config/exec_provider.py

@@ -15,6 +15,7 @@
 import os
 import subprocess
 import sys
+import platform
 
 from .config_exception import ConfigException
 
@@ -83,15 +84,17 @@ def run(self, previous_response=None):
             kubernetes_exec_info['spec']['cluster'] = self.cluster.value
 
         self.env['KUBERNETES_EXEC_INFO'] = json.dumps(kubernetes_exec_info)
+        is_windows = platform.system() == "Windows"
         process = subprocess.Popen(
-            self.args,
-            stdout=subprocess.PIPE,
-            stderr=sys.stderr if is_interactive else subprocess.PIPE,
-            stdin=sys.stdin if is_interactive else None,
-            cwd=self.cwd,
-            env=self.env,
-            universal_newlines=True,
-            shell=self.shell)
+          self.args,
+          stdout=subprocess.PIPE,
+          stderr=sys.stderr if is_interactive else subprocess.PIPE,
+          stdin=sys.stdin if is_interactive else None,
+          cwd=self.cwd,
+          env=self.env,
+          universal_newlines=True,
+          shell=is_windows  # Only use shell=True on Windows
+        )
         (stdout, stderr) = process.communicate()
         exit_code = process.wait()
         if exit_code != 0:

kubernetes/base/stream/ws_client.py

@@ -469,7 +469,7 @@ def create_websocket(configuration, url, headers=None):
         header.append("sec-websocket-protocol: %s" %
                       headers['sec-websocket-protocol'])
     else:
-        header.append("sec-websocket-protocol: v4.channel.k8s.io")
+        header.append("sec-websocket-protocol: v5.channel.k8s.io")
 
     if url.startswith('wss://') and configuration.verify_ssl:
         ssl_opts = {

kubernetes/base/watch/watch.py

@@ -76,8 +76,7 @@ def iter_resp_lines(resp):
             line = buffer[:next_newline].decode(
                 "utf-8", errors="replace")
             buffer = buffer[next_newline+1:]
-            if line:
-                yield line
+            yield line
             next_newline = buffer.find(b'\n')