hadoop: Fix CDH3 mkdir implementation (#2188)

spotify · Jul 21, 2017 · eca47ff · eca47ff
1 parent 7636ae3
commit eca47ff
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/luigi/contrib/hdfs/hadoopcli_clients.py b/luigi/contrib/hdfs/hadoopcli_clients.py
@@ -230,7 +230,8 @@ def mkdir(self, path, parents=True, raise_if_exists=False):
             self.call_check(load_hadoop_cmd() + ['fs', '-mkdir', path])
         except hdfs_error.HDFSCliError as ex:
             if "File exists" in ex.stderr:
-                raise FileAlreadyExists(ex.stderr)
+                if raise_if_exists:
+                    raise FileAlreadyExists(ex.stderr)
             else:
                 raise