You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tez.apache.org by hi...@apache.org on 2014/03/04 01:10:03 UTC
git commit: TEZ-893. Terasort gives ArrayIndexOutOfBound Exception
for 'hadoop jar terasort'. (hitesh)
Repository: incubator-tez
Updated Branches:
refs/heads/master 2ff672075 -> ee7f3850a
TEZ-893. Terasort gives ArrayIndexOutOfBound Exception for 'hadoop jar <jar> terasort'. (hitesh)
Project: http://git-wip-us.apache.org/repos/asf/incubator-tez/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-tez/commit/ee7f3850
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tez/tree/ee7f3850
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tez/diff/ee7f3850
Branch: refs/heads/master
Commit: ee7f3850a7412600caadfa784411c0b1fcf92f82
Parents: 2ff6720
Author: Hitesh Shah <hi...@apache.org>
Authored: Mon Mar 3 16:09:33 2014 -0800
Committer: Hitesh Shah <hi...@apache.org>
Committed: Mon Mar 3 16:09:33 2014 -0800
----------------------------------------------------------------------
.../org/apache/tez/mapreduce/examples/terasort/TeraSort.java | 6 ++++++
1 file changed, 6 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-tez/blob/ee7f3850/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/terasort/TeraSort.java
----------------------------------------------------------------------
diff --git a/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/terasort/TeraSort.java b/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/terasort/TeraSort.java
index bbfa8e5..5a097f2 100644
--- a/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/terasort/TeraSort.java
+++ b/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/terasort/TeraSort.java
@@ -278,6 +278,12 @@ public class TeraSort extends Configured implements Tool {
}
public int run(String[] args) throws Exception {
+ if (args.length != 2) {
+ System.err.println("Invalid no. of arguments provided");
+ System.err.println("Usage: terasort <input-dir> <output-dir>");
+ return -1;
+ }
+
LOG.info("starting");
Job job = Job.getInstance(getConf());
Path inputDir = new Path(args[0]);