|
@@ -24,7 +24,6 @@ import org.apache.hadoop.fs.FSDataOutputStream;
|
|
|
import org.apache.hadoop.fs.FileSystem;
|
|
|
import org.apache.hadoop.fs.Path;
|
|
|
import org.apache.hadoop.io.Text;
|
|
|
-import org.apache.hadoop.mapred.FileAlreadyExistsException;
|
|
|
import org.apache.hadoop.mapred.InvalidJobConfException;
|
|
|
import org.apache.hadoop.mapreduce.JobContext;
|
|
|
import org.apache.hadoop.mapreduce.OutputCommitter;
|
|
@@ -91,11 +90,6 @@ public class TeraOutputFormat extends FileOutputFormat<Text,Text> {
|
|
|
// get delegation token for outDir's file system
|
|
|
TokenCache.obtainTokensForNamenodes(job.getCredentials(),
|
|
|
new Path[] { outDir }, job.getConfiguration());
|
|
|
-
|
|
|
- if (outDir.getFileSystem(job.getConfiguration()).exists(outDir)) {
|
|
|
- throw new FileAlreadyExistsException("Output directory " + outDir +
|
|
|
- " already exists");
|
|
|
- }
|
|
|
}
|
|
|
|
|
|
public RecordWriter<Text,Text> getRecordWriter(TaskAttemptContext job
|