We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 0d766be commit d68dbebCopy full SHA for d68dbeb
src/edu/jhu/thrax/hadoop/jobs/OutputJob.java
@@ -74,14 +74,6 @@ public Job getJob(Configuration conf) throws IOException {
74
if (FileInputFormat.getInputPaths(job).length == 0) {
75
// TODO: This is going to crash.
76
FileInputFormat.addInputPath(job, new Path(workDir + "rules"));
77
- } else {
78
- // We have at least one feature to aggregate, so we don't need
79
- // the rules sub-directory at all at this point.
80
- // We delete it to save disk space.
81
- final FileSystem fs = FileSystem.get(conf);
82
- final Path rulesPath = new Path(workDir + "rules");
83
- final boolean recursive = true;
84
- fs.delete(rulesPath, recursive);
85
}
86
87
String outputPath = conf.get("thrax.outputPath", "");
0 commit comments