From fcf47eb4b8cf0cb39f0c70845048f5cf4d9ef947 Mon Sep 17 00:00:00 2001 From: Harsh J Date: Mon, 28 May 2012 13:26:35 +0000 Subject: [PATCH] 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 --- hadoop-mapreduce-project/CHANGES.txt | 3 +++ .../src/test/java/org/apache/hadoop/mapred/MRBench.java | 4 ++-- 2 files changed, 5 insertions(+), 2 deletions(-) diff --git a/hadoop-mapreduce-project/CHANGES.txt b/hadoop-mapreduce-project/CHANGES.txt index 74be26b580..1344da9d1d 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 bb287cf155..20d27fbe51 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")) {