Github user tdas commented on a diff in the pull request:
https://github.com/apache/spark/pull/20650#discussion_r169605952
--- Diff:
sql/core/src/test/scala/org/apache/spark/sql/streaming/StreamTest.scala ---
@@ -425,243 +444,248 @@ trait StreamTest extends QueryTest with
SharedSQLContext with TimeLimits with Be
}
}
- var manualClockExpectedTime = -1L
- val defaultCheckpointLocation =
- Utils.createTempDir(namePrefix =
"streaming.metadata").getCanonicalPath
- try {
- startedTest.foreach { action =>
- logInfo(s"Processing test stream action: $action")
- action match {
- case StartStream(trigger, triggerClock, additionalConfs,
checkpointLocation) =>
- verify(currentStream == null, "stream already running")
- verify(triggerClock.isInstanceOf[SystemClock]
- || triggerClock.isInstanceOf[StreamManualClock],
- "Use either SystemClock or StreamManualClock to start the
stream")
- if (triggerClock.isInstanceOf[StreamManualClock]) {
- manualClockExpectedTime =
triggerClock.asInstanceOf[StreamManualClock].getTimeMillis()
+ def performAction(action: StreamAction): Unit = {
--- End diff --
TODO: Add docs.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
