diff --git a/hadoop-mapreduce-project/CHANGES.txt b/hadoop-mapreduce-project/CHANGES.txt index 74be26b580a..1344da9d1d0 100644 --- a/hadoop-mapreduce-project/CHANGES.txt +++ b/hadoop-mapreduce-project/CHANGES.txt @@ -115,6 +115,9 @@ Trunk (unreleased changes) MAPREDUCE-1740. NPE in getMatchingLevelForNodes when node locations are variable depth (ahmed via tucu) [IMPORTANT: this is dead code in trunk] + MAPREDUCE-3990. MRBench allows Long-sized input-lines value + but parses CLI argument as an Integer. (harsh) + Release 2.0.1-alpha - UNRELEASED INCOMPATIBLE CHANGES diff --git a/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-jobclient/src/test/java/org/apache/hadoop/mapred/MRBench.java b/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-jobclient/src/test/java/org/apache/hadoop/mapred/MRBench.java index bb287cf155a..20d27fbe517 100644 --- a/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-jobclient/src/test/java/org/apache/hadoop/mapred/MRBench.java +++ b/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-jobclient/src/test/java/org/apache/hadoop/mapred/MRBench.java @@ -230,7 +230,7 @@ public int run(String[] args) throws Exception { "[-verbose]"; String jarFile = null; - int inputLines = 1; + long inputLines = 1; int numRuns = 1; int numMaps = 2; int numReduces = 1; @@ -248,7 +248,7 @@ public int run(String[] args) throws Exception { } else if (args[i].equals("-reduces")) { numReduces = Integer.parseInt(args[++i]); } else if (args[i].equals("-inputLines")) { - inputLines = Integer.parseInt(args[++i]); + inputLines = Long.parseLong(args[++i]); } else if (args[i].equals("-inputType")) { String s = args[++i]; if (s.equalsIgnoreCase("ascending")) {