diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/tez/HiveSplitGenerator.java ql/src/java/org/apache/hadoop/hive/ql/exec/tez/HiveSplitGenerator.java index 87881b6..51327db 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/tez/HiveSplitGenerator.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/tez/HiveSplitGenerator.java @@ -137,7 +137,7 @@ public HiveSplitGenerator(InputInitializerContext initializerContext) throws IOE if (conf.getLong(MIN_SPLIT_SIZE, 1) <= 1) { // broken configuration from mapred-default.xml - final long blockSize = conf.getLong(DFSConfigKeys.DFS_BLOCK_SIZE_KEY, + final long blockSize = conf.getLongBytes(DFSConfigKeys.DFS_BLOCK_SIZE_KEY, DFSConfigKeys.DFS_BLOCK_SIZE_DEFAULT); final long minGrouping = conf.getLong( TezMapReduceSplitsGrouper.TEZ_GROUPING_SPLIT_MIN_SIZE,