diff --git a/aztk/clusterlib.py b/aztk/clusterlib.py
index 04f5c679..c7ecb8d8 100644
--- a/aztk/clusterlib.py
+++ b/aztk/clusterlib.py
@@ -543,8 +543,7 @@ def ssh_in_master(
             ssh_command.add_argument("\'sudo docker exec -it spark /bin/bash\'")
 
         command = ssh_command.to_str()
-        ssh_command_array = command.split()
 
         if connect:
-            call(ssh_command_array)
+            call(command, shell=True)
         return '\n\t{}\n'.format(command)