It looks like there is no way to set the number of reduces with V2 style arguments.
It seems this was supported with V1 style arguments.
int maxTasks = Integer.parseInt(args[2]);
job.setInt("mapred.reduce.tasks", maxTasks);
Is there any specific reason that it is not available in V2 or am I missing something?
It looks like there is no way to set the number of reduces with V2 style arguments.
It seems this was supported with V1 style arguments.
int maxTasks = Integer.parseInt(args[2]);
job.setInt("mapred.reduce.tasks", maxTasks);
Is there any specific reason that it is not available in V2 or am I missing something?