Update 2.1 JobScheduler, Job, JobSet 详解.md

toints · Aug 10, 2016 · 1042350 · 1042350
1 parent 33ee00f
commit 1042350
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
@@ -248,7 +248,7 @@ object ConcurrentJobsDemo {
       // invoke store("str") every 100ms
       Executors.newScheduledThreadPool(1).scheduleAtFixedRate(new Runnable {
         override def run(): Unit = store("str")
-      }, 0, 10, TimeUnit.MILLISECONDS)
+      }, 0, 100, TimeUnit.MILLISECONDS)
     }
 
     override def onStop() {}