diff options
| author | Tathagata Das <tathagata.das1565@gmail.com> | 2013-02-18 02:12:41 -0800 |
|---|---|---|
| committer | Tathagata Das <tathagata.das1565@gmail.com> | 2013-02-18 02:12:41 -0800 |
| commit | 8ad561dc7d6475d7b217ec3f57bac3b584fed31a (patch) | |
| tree | 84f990d67335abc27c5ba126c75f31d4452a0295 /streaming/src/test | |
| parent | f98c7da23ef66812b8b4888230ee98c07f09af23 (diff) | |
| download | spark-8ad561dc7d6475d7b217ec3f57bac3b584fed31a.tar.gz spark-8ad561dc7d6475d7b217ec3f57bac3b584fed31a.tar.bz2 spark-8ad561dc7d6475d7b217ec3f57bac3b584fed31a.zip | |
Added checkpointing and fault-tolerance semantics to the programming guide. Fixed default checkpoint interval to being a multiple of slide duration. Fixed visibility of some classes and objects to clean up docs.
Diffstat (limited to 'streaming/src/test')
| -rw-r--r-- | streaming/src/test/scala/spark/streaming/CheckpointSuite.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/streaming/src/test/scala/spark/streaming/CheckpointSuite.scala b/streaming/src/test/scala/spark/streaming/CheckpointSuite.scala index 5250667bcb..cac86deeaf 100644 --- a/streaming/src/test/scala/spark/streaming/CheckpointSuite.scala +++ b/streaming/src/test/scala/spark/streaming/CheckpointSuite.scala @@ -50,7 +50,7 @@ class CheckpointSuite extends TestSuiteBase with BeforeAndAfter { val stateStreamCheckpointInterval = Seconds(1) // this ensure checkpointing occurs at least once - val firstNumBatches = (stateStreamCheckpointInterval / batchDuration) * 2 + val firstNumBatches = (stateStreamCheckpointInterval / batchDuration).toLong * 2 val secondNumBatches = firstNumBatches // Setup the streams |