0

I am trying to delete a hadoop directory using a python script

__removeDir__ = subprocess.call(['hadoop','fs','-rmr',targetdir],stdout = subprocess.PIPE, stderr = subprocess.PIPE)

targetdir is a python variable from the same script.

The above command is not working. Also, I would like to know if there is any API provided to the hadoop filesystem in python.

wandermonk
  • 6,856
  • 6
  • 43
  • 93

0 Answers0