Github user srowen commented on a diff in the pull request:
https://github.com/apache/spark/pull/19561#discussion_r146342877
--- Diff:
sql/core/src/test/scala/org/apache/spark/sql/streaming/StreamingQuerySuite.scala
---
@@ -744,7 +744,7 @@ class StreamingQuerySuite extends StreamTest with
BeforeAndAfter with Logging wi
assert(returnedValue === expectedReturnValue, "Returned value
does not match expected")
}
}
- AwaitTerminationTester.test(expectedBehavior, awaitTermFunc)
+ AwaitTerminationTester.test(expectedBehavior, () => awaitTermFunc())
--- End diff --
The rest here are just 2.12 warning cleanups by the by
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
