Details
-
Bug
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
None
-
None
-
None
Description
In HiveConf.java ...
MAPREDMINSPLITSIZEPERNODE("mapred.min.split.size.per.rack", 1L), MAPREDMINSPLITSIZEPERRACK("mapred.min.split.size.per.node", 1L),
Then, in ExecDriver.java ...
if (mWork.getMinSplitSizePerNode() != null) { HiveConf.setLongVar(job, HiveConf.ConfVars.MAPREDMINSPLITSIZEPERNODE, mWork.getMinSplitSizePerNode().longValue()); } if (mWork.getMinSplitSizePerRack() != null) { HiveConf.setLongVar(job, HiveConf.ConfVars.MAPREDMINSPLITSIZEPERRACK, mWork.getMinSplitSizePerRack().longValue()); }
Attachments
Issue Links
- duplicates
-
HIVE-6572 Use shimmed version of hadoop conf names for mapred.{min,max}.split.size{.*}
- Resolved