Hi,
There seems to be some problem in overwriting existing empty directory.
Here is how you can recreate it:
1. Create empty output directory with only _SUCCESS file in it "tempout/_SUCCESS"
2. Now try to overwrite same directory with some data. Overwrite creates output file "tempout/ch9-13/out-m-00000" instead of "tempout/out-m-00000"
object Temp extends ScoobiApp {
def run = {
//create empty directory
val temp1 = DList[Int]()
persist(temp1.toTextFile("tempout", overwrite = true))
//overwrite it
val temp2 = DList(1, 2, 3, 4)
persist(temp2.toTextFile("tempout", overwrite = true))
}
}
Thanks,
Sandip