From 29b11f6388b437e46bd9d8df564d55647c65c9e1 Mon Sep 17 00:00:00 2001 From: Robin Aggleton Date: Mon, 23 May 2016 13:59:34 +0100 Subject: [PATCH] Actually fix the /hdfs removal bug --- htcondenser/core/common.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/htcondenser/core/common.py b/htcondenser/core/common.py index a205b2a..a8d2f14 100644 --- a/htcondenser/core/common.py +++ b/htcondenser/core/common.py @@ -44,7 +44,7 @@ def check_dir_create(directory): """ if not os.path.isdir(directory): if os.path.abspath(directory).startswith('/hdfs'): - check_call(['hadoop', 'fs', '-mkdir', '-p', os.path.abspath(directory).replace('/hdfs', '/')]) + check_call(['hadoop', 'fs', '-mkdir', '-p', os.path.abspath(directory).replace('/hdfs', '')]) else: os.makedirs(directory)