Apache
/
hadoop
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

MAPREDUCE-3990. MRBench allows Long-sized input-lines value but parses CLI argument as an Integer. (harsh) 

git-svn-id: https://svn.apache.org/repos/asf/hadoop/common/trunk@1343247 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Harsh J 2012-05-28 13:26:35 +00:00
parent 0037bf5dc5
commit fcf47eb4b8
2 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
hadoop-mapreduce-project/CHANGES.txt
View File

@ -115,6 +115,9 @@ Trunk (unreleased changes)
MAPREDUCE-1740. NPE in getMatchingLevelForNodes when node locations are MAPREDUCE-1740. NPE in getMatchingLevelForNodes when node locations are
variable depth (ahmed via tucu) [IMPORTANT: this is dead code in trunk] 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 Release 2.0.1-alpha - UNRELEASED
INCOMPATIBLE CHANGES INCOMPATIBLE CHANGES

4
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-jobclient/src/test/java/org/apache/hadoop/mapred/MRBench.java
View File

@ -230,7 +230,7 @@ public class MRBench extends Configured implements Tool{
"[-verbose]"; "[-verbose]";
String jarFile = null; String jarFile = null;
int inputLines = 1; long inputLines = 1;
int numRuns = 1; int numRuns = 1;
int numMaps = 2; int numMaps = 2;
int numReduces = 1; int numReduces = 1;
@ -248,7 +248,7 @@ public class MRBench extends Configured implements Tool{
} else if (args[i].equals("-reduces")) { } else if (args[i].equals("-reduces")) {
numReduces = Integer.parseInt(args[++i]); numReduces = Integer.parseInt(args[++i]);
} else if (args[i].equals("-inputLines")) { } else if (args[i].equals("-inputLines")) {
inputLines = Integer.parseInt(args[++i]); inputLines = Long.parseLong(args[++i]);
} else if (args[i].equals("-inputType")) { } else if (args[i].equals("-inputType")) {
String s = args[++i]; String s = args[++i];
if (s.equalsIgnoreCase("ascending")) { if (s.equalsIgnoreCase("ascending")) {