Minor Description
When KeyValueTextInputFormat selected as job input format, worker tasks are getting only one value for given key.
Reason: In PartitioningRunner class for collecting data into memory used Map<Integer, Map<Writable, Writable>>, where Integer for worker id, Map is for key/values, if multiple values for same key, all values will be overwritten by the last value.
