Details
-
Bug
-
Status: Open
-
Minor
-
Resolution: Unresolved
-
None
-
None
Description
Example:
job.setPartitioner(HashPartitioner.class);
job.setInputFormat(KeyValueTextInputFormat.class);
KeyValueTextInputFormat.addInputPaths(job, "/tmp/test.seq,/tmp/test2.seq,/tmp/test3.seq");
HashPartitioner is not called when task count == input path count