Skip to content

Commit c9d1927

Browse files
committed
Update BlockGenerator.scala
1 parent bd3f71a commit c9d1927

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

streaming/src/main/scala/org/apache/spark/streaming/receiver/BlockGenerator.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -80,7 +80,7 @@ private[streaming] class BlockGenerator(
8080

8181
private val clock = new SystemClock()
8282
private val blockIntervalMs = conf.getTimeAsMs("spark.streaming.blockInterval", "200ms")
83-
require(blockIntervalMs > 0 ,s"'spark.streaming.blockInterval' should be a positive value")
83+
require(blockIntervalMs > 0, s"'spark.streaming.blockInterval' should be a positive value")
8484

8585
private val blockIntervalTimer =
8686
new RecurringTimer(clock, blockIntervalMs, updateCurrentBuffer, "BlockGenerator")

0 commit comments

Comments
 (0)