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 1a32a4b commit d7cd15bCopy full SHA for d7cd15b
streaming/src/test/scala/org/apache/spark/streaming/ReceiverSuite.scala
@@ -225,7 +225,7 @@ class ReceiverSuite extends TestSuiteBase with Timeouts with Serializable {
225
.setAppName(framework)
226
.set("spark.ui.enabled", "true")
227
.set("spark.streaming.receiver.writeAheadLog.enable", "true")
228
- .set("spark.streaming.receiver.writeAheadLog.rollingInterval", "1")
+ .set("spark.streaming.receiver.writeAheadLog.rollingIntervalSecs", "1")
229
val batchDuration = Milliseconds(500)
230
val tempDirectory = Utils.createTempDir()
231
val logDirectory1 = new File(checkpointDirToLogDir(tempDirectory.getAbsolutePath, 0))
0 commit comments