Skip to content

Commit

Permalink
Fixed a tempfile name
Browse files Browse the repository at this point in the history
  • Loading branch information
csrster committed Jan 25, 2022
1 parent c5d6c5d commit 31fc8d3
Showing 1 changed file with 1 addition and 1 deletion.
Expand Up @@ -461,7 +461,7 @@ private static File getCrawlLogUsingHadoop(long jobID) {
job.prepareJobInputOutput(fileSystem);
job.run();
File tempOutputFile1 = File.createTempFile("unsorted_crawl", "log");
File tempOutputFile2 = File.createTempFile("unsorted_crawl", "log");
File tempOutputFile2 = File.createTempFile("sorted_crawl", "log");
log.info("Collecting output from {} to {}", job.getJobOutputDir(), tempOutputFile1.getAbsolutePath());
try (OutputStream os = new FileOutputStream(tempOutputFile1)) {
HadoopJobUtils.collectOutputLines(fileSystem, job.getJobOutputDir(), os);
Expand Down

0 comments on commit 31fc8d3

Please sign in to comment.