Skip to content
Permalink
Browse files

[SPARK-23198][SS][TEST] Fix KafkaContinuousSourceStressForDontFailOnD…

…ataLossSuite to test ContinuousExecution

## What changes were proposed in this pull request?

Currently, `KafkaContinuousSourceStressForDontFailOnDataLossSuite` runs on `MicroBatchExecution`. It should test `ContinuousExecution`.

## How was this patch tested?

Pass the updated test suite.

Author: Dongjoon Hyun <dongjoon@apache.org>

Closes #20374 from dongjoon-hyun/SPARK-23198.

(cherry picked from commit bc9641d)
Signed-off-by: Shixiong Zhu <zsxwing@gmail.com>
  • Loading branch information...
dongjoon-hyun authored and zsxwing committed Jan 24, 2018
1 parent 30272c6 commit 500c94434d8f5267b1488accd176cf54b69e6ba4
@@ -91,6 +91,7 @@ class KafkaContinuousSourceStressForDontFailOnDataLossSuite
ds.writeStream
.format("memory")
.queryName("memory")
.trigger(Trigger.Continuous("1 second"))
.start()
}
}

0 comments on commit 500c944

Please sign in to comment.
You can’t perform that action at this time.