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: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org

Reply via email to