Hadoop Pig cannot store to an existing folder Hadoop Pig cannot store to an existing folder hadoop hadoop

Hadoop Pig cannot store to an existing folder


You can execute fs commands from within Pig, and should be able to delete the directory by issuing a fs -rmr command before running the STORE command:

fs -rmr dirSTORE A into 'dir' using PigStorage();

The only subtly is the fs command doesn't expect quotes around the directory name, whereas the store command does expect quotes around the directory name.