hadoop: use --force when removing data

Signed-off-by: Ruslan Kuprieiev <[email protected]>
2026-11-06 15:28:28 +01:00 · 2019-03-29 21:31:22 +02:00
parent db11175ad9
commit 278f817ec7
1 changed files with 1 additions and 1 deletions
@@ -77,7 +77,7 @@ class RemoteHDFS(RemoteBase):

    def rm(self, path_info):
        self.hadoop_fs(
-            "rm {}".format(path_info["path"]), user=path_info["user"]
+            "rm -f {}".format(path_info["path"]), user=path_info["user"]
        )

    def save_info(self, path_info):