diff options
| author | azuryyu <azuryyyu@gmail.com> | 2013-12-24 16:52:20 +0800 |
|---|---|---|
| committer | azuryyu <azuryyyu@gmail.com> | 2013-12-24 16:52:20 +0800 |
| commit | a8bb86389d8dc8efeff83561aea044a3c4924df5 (patch) | |
| tree | 03b3ad40661d080a7592f6410588abd0fa6ad111 /examples | |
| parent | c64a53a48b894c3b5f4631eb0549c3292cd3d167 (diff) | |
| download | spark-a8bb86389d8dc8efeff83561aea044a3c4924df5.tar.gz spark-a8bb86389d8dc8efeff83561aea044a3c4924df5.tar.bz2 spark-a8bb86389d8dc8efeff83561aea044a3c4924df5.zip | |
Fixed job name in the java streaming example.
Diffstat (limited to 'examples')
| -rw-r--r-- | examples/src/main/java/org/apache/spark/streaming/examples/JavaKafkaWordCount.java | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/examples/src/main/java/org/apache/spark/streaming/examples/JavaKafkaWordCount.java b/examples/src/main/java/org/apache/spark/streaming/examples/JavaKafkaWordCount.java index 9a8e4209ed..22994fb2ec 100644 --- a/examples/src/main/java/org/apache/spark/streaming/examples/JavaKafkaWordCount.java +++ b/examples/src/main/java/org/apache/spark/streaming/examples/JavaKafkaWordCount.java @@ -53,7 +53,7 @@ public class JavaKafkaWordCount { } // Create the context with a 1 second batch size - JavaStreamingContext ssc = new JavaStreamingContext(args[0], "NetworkWordCount", + JavaStreamingContext ssc = new JavaStreamingContext(args[0], "KafkaWordCount", new Duration(2000), System.getenv("SPARK_HOME"), System.getenv("SPARK_EXAMPLES_JAR")); int numThreads = Integer.parseInt(args[4]); |