diff --git a/sahara/service/edp/spark/engine.py b/sahara/service/edp/spark/engine.py
index 83a35ff3d4..40a0e6beb8 100644
--- a/sahara/service/edp/spark/engine.py
+++ b/sahara/service/edp/spark/engine.py
@@ -173,7 +173,7 @@ class SparkJobEngine(base_engine.JobEngine):
                 job_configs.get('configs', {})):
             path = 'service/edp/resources/edp-spark-wrapper.jar'
             name = 'builtin-%s.jar' % uuidutils.generate_uuid()
-            builtin_libs = [{'raw': files.get_file_text(path),
+            builtin_libs = [{'raw': files.try_get_file_text(path),
                              'name': name}]
 
         uploaded_paths = []
diff --git a/sahara/utils/ssh_remote.py b/sahara/utils/ssh_remote.py
index c6da6601d3..a45332e6a5 100644
--- a/sahara/utils/ssh_remote.py
+++ b/sahara/utils/ssh_remote.py
@@ -276,7 +276,11 @@ def _get_http_client(host, port, proxy_command=None, gateway_host=None,
 
 
 def _write_fl(sftp, remote_file, data):
-    write_data = paramiko.py3compat.StringIO(data)
+    try:
+        write_data = paramiko.py3compat.StringIO(data)
+    except TypeError:
+        write_data = paramiko.py3compat.BytesIO(data)
+
     sftp.putfo(write_data, remote_file)