aboutsummaryrefslogtreecommitdiff
path: root/examples
diff options
context:
space:
mode:
authorPatrick Wendell <pwendell@gmail.com>2014-01-22 14:32:59 -0800
committerPatrick Wendell <pwendell@gmail.com>2014-01-22 14:32:59 -0800
commita1238bb5fcab763d32c729ea7ed99cb3c05c896f (patch)
treef242a3cfaf9a8120533fd6a2ecb32bab8cf19b69 /examples
parent576c4a4c502ccca5fcd6b3552dd93cc2f3c50666 (diff)
parent36f9a64ec9b09309df82865a0caa482b7a3ffce0 (diff)
downloadspark-a1238bb5fcab763d32c729ea7ed99cb3c05c896f.tar.gz
spark-a1238bb5fcab763d32c729ea7ed99cb3c05c896f.tar.bz2
spark-a1238bb5fcab763d32c729ea7ed99cb3c05c896f.zip
Merge pull request #492 from skicavs/master
fixed job name and usage information for the JavaSparkPi example
Diffstat (limited to 'examples')
-rw-r--r--examples/src/main/java/org/apache/spark/examples/JavaSparkPi.java4
1 files changed, 2 insertions, 2 deletions
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 3ec4a58d48..ac8df02c46 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;