Details
-
Bug
-
Status: Closed
-
Major
-
Resolution: Fixed
-
None
-
None
-
None
Description
MAP_INPUT_BYTES and MAP_OUTPUT_BYTES will be computed using the difference between FileSystem
counters before and after each next(K,V) and collect/write op.
In case compression is being used, these counters will represent the compressed data sizes. The uncompressed size will
not be available.
This is not a direct back-port of 5710. (Counters will be computed in MapTask instead of in individual RecordReaders).
0.20.100 ->
New API -> MAP_INPUT_BYTES will be computed using this method
Old API -> MAP_INPUT_BYTES will remain unchanged.
0.23 ->
New API -> MAP_INPUT_BYTES will be computed using this method
Old API -> MAP_INPUT_BYTES likely to use this method