Fix WordCount job name

2012-08-24 16:43:59 -07:00 · 2012-08-24 16:43:59 -07:00 · 091b1438f5
parent 5a8015d2db
commit 091b1438f5
1 changed files with 1 additions and 1 deletions
--- a/streaming/src/main/scala/spark/streaming/examples/WordCount.scala
+++ b/streaming/src/main/scala/spark/streaming/examples/WordCount.scala
@ -11,7 +11,7 @@ object WordCount {
    }

    // Create the context and set the batch size
-    val ssc = new SparkStreamContext(args(0), "ExampleTwo")
+    val ssc = new SparkStreamContext(args(0), "WordCount")
    ssc.setBatchDuration(Seconds(2))

    // Create the FileInputDStream on the directory and use the