Bug: Ensure Directories Exist Before Copying (#342)

This commit is contained in:
Jacob Freck 2018-01-22 16:13:13 -05:00 коммит произвёл GitHub
Родитель 1aae3b5a8b
Коммит 717f3d04a3
Не найден ключ, соответствующий данной подписи
Идентификатор ключа GPG: 4AEE18F83AFDEB23
1 изменённых файлов: 2 добавлений и 1 удалений

Просмотреть файл

@ -117,6 +117,7 @@ def start_spark_worker():
def copyfile(src, dest):
try:
os.makedirs(dest, exist_ok=True)
shutil.copyfile(src, dest)
file_stat = os.stat(dest)
os.chmod(dest, file_stat.st_mode | 0o777)
@ -177,7 +178,7 @@ def copy_jars():
src = os.path.join(spark_default_path_src, jar)
dest = os.path.join(spark_default_path_dest, jar)
print("copy {} to {}".format(src, dest))
shutil.copyfile(src, dest)
copyfile(src, dest)
except Exception as e:
print("Failed to copy jar files with error:")
print(e)