Github user MrBago commented on a diff in the pull request:
https://github.com/apache/spark/pull/19843#discussion_r153964308
--- Diff:
sql/core/src/test/scala/org/apache/spark/sql/streaming/StreamTest.scala ---
@@ -573,8 +578,19 @@ trait StreamTest extends QueryTest with
SharedSQLContext with TimeLimits with Be
failTest("Exception while getting data from sink", e)
}
- QueryTest.sameRows(expectedAnswer, sparkAnswer,
isSorted).foreach {
- error => failTest(error)
+ if (expectedAnswer != null) {
+ QueryTest.sameRows(expectedAnswer, sparkAnswer,
isSorted).foreach {
+ error => failTest(error)
+ }
+ } else {
+ assert(checkFunction != null)
+ sparkAnswer.foreach { row =>
+ try {
+ checkFunction
--- End diff --
Should this be `checkFunction(row)`?
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
