We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 520bade commit 1304776Copy full SHA for 1304776
streaming/src/test/scala/org/apache/spark/streaming/CheckpointSuite.scala
@@ -276,7 +276,7 @@ class CheckpointSuite extends TestSuiteBase {
276
// the master failure and uses them again to process a large window operation.
277
// It also tests whether batches, whose processing was incomplete due to the
278
// failure, are re-processed or not.
279
- test("recovery with file input ztream") {
+ test("recovery with file input stream") {
280
// Set up the streaming context and input streams
281
val batchDuration = Seconds(2) // Due to 1-second resolution of setLastModified() on some OS's.
282
val testDir = Utils.createTempDir()
0 commit comments