diff options
| author | Matei Zaharia <matei@eecs.berkeley.edu> | 2012-08-24 16:43:59 -0700 |
|---|---|---|
| committer | Matei Zaharia <matei@eecs.berkeley.edu> | 2012-08-24 16:43:59 -0700 |
| commit | 091b1438f53b810fa366c3e913174d380865cd0c (patch) | |
| tree | a1c2f36bd95a8c4ac641131921aa906e10cfc760 /streaming | |
| parent | 5a8015d2dbe1a475a7c921fbf850abe594be5867 (diff) | |
| download | spark-091b1438f53b810fa366c3e913174d380865cd0c.tar.gz spark-091b1438f53b810fa366c3e913174d380865cd0c.tar.bz2 spark-091b1438f53b810fa366c3e913174d380865cd0c.zip | |
Fix WordCount job name
Diffstat (limited to 'streaming')
| -rw-r--r-- | streaming/src/main/scala/spark/streaming/examples/WordCount.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/streaming/src/main/scala/spark/streaming/examples/WordCount.scala b/streaming/src/main/scala/spark/streaming/examples/WordCount.scala index ba7bc63d6a..6c53007145 100644 --- 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 |