Actually fix the /hdfs removal bug

kreczko · May 23, 2016 · 29b11f6 · 29b11f6
1 parent c39fad3
commit 29b11f6
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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)