修复一处注释的 typo

toints · Aug 10, 2016 · d410791 · d410791
1 parent 7f9fa7c
commit d410791
Showing 1 changed file with 3 additions and 3 deletions.
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 定义结束
 ...
 ```