Skip to content

Commit

Permalink
Small job change for clarity in cluster job overview
Browse files Browse the repository at this point in the history
  • Loading branch information
Bohlski committed Feb 24, 2021
1 parent 9e06be7 commit 7af86eb
Showing 1 changed file with 2 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -37,7 +37,8 @@ public int run(String[] args) throws InterruptedException, IOException, ClassNot
Path inputPath = new Path(args[0]);
Path outputPath = new Path(args[1]);
Configuration conf = getConf();
Job job = Job.getInstance(conf, this.getClass().getName());
Job job = Job.getInstance(conf);
job.setJobName("HadoopJob using " + mapper.getClass().getSimpleName());

//job.setJarByClass(this.getClass());
job.setInputFormatClass(NLineInputFormat.class);
Expand Down

0 comments on commit 7af86eb

Please sign in to comment.