diff options
| author | seanm <sean.mcnamara@webtrends.com> | 2013-04-16 11:57:05 -0600 |
|---|---|---|
| committer | seanm <sean.mcnamara@webtrends.com> | 2013-04-16 11:57:05 -0600 |
| commit | ab0f834dbb509d323577572691293b74368a9d86 (patch) | |
| tree | 6c00e870d03b1f108f9c76b92b91619626957785 /streaming | |
| parent | 8ac9efba5a435443be9abf8ebbe867806d42c9db (diff) | |
| download | spark-ab0f834dbb509d323577572691293b74368a9d86.tar.gz spark-ab0f834dbb509d323577572691293b74368a9d86.tar.bz2 spark-ab0f834dbb509d323577572691293b74368a9d86.zip | |
adding spark.streaming.blockInterval property
Diffstat (limited to 'streaming')
| -rw-r--r-- | streaming/src/main/scala/spark/streaming/dstream/NetworkInputDStream.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/streaming/src/main/scala/spark/streaming/dstream/NetworkInputDStream.scala b/streaming/src/main/scala/spark/streaming/dstream/NetworkInputDStream.scala index 7385474963..26805e9621 100644 --- a/streaming/src/main/scala/spark/streaming/dstream/NetworkInputDStream.scala +++ b/streaming/src/main/scala/spark/streaming/dstream/NetworkInputDStream.scala @@ -198,7 +198,7 @@ abstract class NetworkReceiver[T: ClassManifest]() extends Serializable with Log case class Block(id: String, iterator: Iterator[T], metadata: Any = null) val clock = new SystemClock() - val blockInterval = 200L + val blockInterval = System.getProperty("spark.streaming.blockInterval", "200").toLong val blockIntervalTimer = new RecurringTimer(clock, blockInterval, updateCurrentBuffer) val blockStorageLevel = storageLevel val blocksForPushing = new ArrayBlockingQueue[Block](1000) |