It tried to remove the tmp output path from wrong fs before compaction.
Closes from treff7es/compaction_tmp_fs_fix
@@ -443,7 +443,7 @@ public abstract class MRCompactorJobRunner implements Runnable, Comparable<MRCom
}
//MR output path must not exist when MR job starts, so delete if exists.
- this.fs.delete(this.dataset.outputTmpPath(), true);
+ this.tmpFs.delete(this.dataset.outputTmpPath(), true);
FileOutputFormat.setOutputPath(job, this.dataset.outputTmpPath());
}
