ConcurrentJobsDemo 中 MyReceiver 构造函数去掉 ()

toints · Aug 10, 2016 · 33ee00f · 33ee00f
1 parent d410791
commit 33ee00f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/Spark Streaming 源码解析系列/2.1 JobScheduler, Job, JobSet 详解.md b/Spark Streaming 源码解析系列/2.1 JobScheduler, Job, JobSet 详解.md
@@ -242,7 +242,7 @@ object ConcurrentJobsDemo {
     ssc.awaitTermination()
   }
 
-  class MyReceiver() extends Receiver[String](StorageLevel.MEMORY_ONLY) {
+  class MyReceiver extends Receiver[String](StorageLevel.MEMORY_ONLY) {
 
     override def onStart() {
       // invoke store("str") every 100ms