Updated Branches: refs/heads/branch-0.9 dd533c9e4 -> dc5857a36
Merge pull request #492 from skicavs/master fixed job name and usage information for the JavaSparkPi example (cherry picked from commit a1238bb5fcab763d32c729ea7ed99cb3c05c896f) Signed-off-by: Patrick Wendell <pwend...@gmail.com> Project: http://git-wip-us.apache.org/repos/asf/incubator-spark/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-spark/commit/dc5857a3 Tree: http://git-wip-us.apache.org/repos/asf/incubator-spark/tree/dc5857a3 Diff: http://git-wip-us.apache.org/repos/asf/incubator-spark/diff/dc5857a3 Branch: refs/heads/branch-0.9 Commit: dc5857a36d2b12208120a0968b8fc1cb38043894 Parents: dd533c9 Author: Patrick Wendell <pwend...@gmail.com> Authored: Wed Jan 22 14:32:59 2014 -0800 Committer: Patrick Wendell <pwend...@gmail.com> Committed: Wed Jan 22 14:33:25 2014 -0800 ---------------------------------------------------------------------- .../src/main/java/org/apache/spark/examples/JavaSparkPi.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-spark/blob/dc5857a3/examples/src/main/java/org/apache/spark/examples/JavaSparkPi.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/spark/examples/JavaSparkPi.java b/examples/src/main/java/org/apache/spark/examples/JavaSparkPi.java index 3ec4a58..ac8df02 100644 --- a/examples/src/main/java/org/apache/spark/examples/JavaSparkPi.java +++ b/examples/src/main/java/org/apache/spark/examples/JavaSparkPi.java @@ -30,11 +30,11 @@ public final class JavaSparkPi { public static void main(String[] args) throws Exception { if (args.length == 0) { - System.err.println("Usage: JavaLogQuery <master> [slices]"); + System.err.println("Usage: JavaSparkPi <master> [slices]"); System.exit(1); } - JavaSparkContext jsc = new JavaSparkContext(args[0], "JavaLogQuery", + JavaSparkContext jsc = new JavaSparkContext(args[0], "JavaSparkPi", System.getenv("SPARK_HOME"), JavaSparkContext.jarOfClass(JavaSparkPi.class)); int slices = (args.length == 2) ? Integer.parseInt(args[1]) : 2;
