Skip to content
Snippets Groups Projects
Commit a1238bb5 authored by Patrick Wendell's avatar Patrick Wendell
Browse files

Merge pull request #492 from skicavs/master

fixed job name and usage information for the JavaSparkPi example
parents 576c4a4c 36f9a64e
No related branches found
No related tags found
No related merge requests found
......@@ -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;
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment