Fix the sleep time

zsxwing · zsxwing · commit 0bcfa87af93f · 2015-05-27T20:50:55.000+08:00
diff --git a/examples/src/main/scala/org/apache/spark/examples/streaming/KafkaWordCount.scala b/examples/src/main/scala/org/apache/spark/examples/streaming/KafkaWordCount.scala
@@ -96,7 +96,7 @@ object KafkaWordCountProducer {
         producer.send(message)
       }
 
-      Thread.sleep(100)
+      Thread.sleep(1000)
     }
   }
 

Original file line number	Diff line number	Diff line change
`@@ -96,7 +96,7 @@ object KafkaWordCountProducer {`
`96`	`96`	`producer.send(message)`
`97`	`97`	`}`
`98`	`98`
`99`		`- Thread.sleep(100)`
	`99`	`+ Thread.sleep(1000)`
`100`	`100`	`}`
`101`	`101`	`}`
`102`	`102`