修复一处注释的 typo

lw-lin · web-flow · commit d410791cecfb · 2016-08-10T14:07:28.000+08:00
diff --git a/Spark Streaming 源码解析系列/2.1 JobScheduler, Job, JobSet 详解.md b/Spark Streaming 源码解析系列/2.1 JobScheduler, Job, JobSet 详解.md
@@ -129,13 +129,13 @@ class JobScheduler(val ssc: StreamingContext) extends Logging {
 // 完整代码可见本文最后的附录
 val BLOCK_INTERVAL = 1 // in seconds
 val BATCH_INTERVAL = 5 // in seconds
-val CURRENT_JOBS = 10  // in seconds
+val CURRENT_JOBS = 10
 ...
 
 // DStream DAG 定义开始
 val inputStream = ssc.receiverStream(...)
-inputStream.foreachRDD(_ => Thread.sleep(Int.MaxValue))  // output 1
-inputStream.foreachRDD(_ => Thread.sleep(Int.MaxValue))  // output 2
+inputStream.foreachRDD(_ => Thread.sleep(Int.MaxValue)) // output 1
+inputStream.foreachRDD(_ => Thread.sleep(Int.MaxValue)) // output 2
 // DStream DAG 定义结束
 ...
 ```
