[SPARK-26120][TESTS][SS][SPARKR] Fix a streaming query leak in Structured Streaming R tests
## What changes were proposed in this pull request? Stop the streaming query in `Specify a schema by using a DDL-formatted string when reading` to avoid outputting annoying logs. ## How was this patch tested? Jenkins Closes #23089 from zsxwing/SPARK-26120. Authored-by: Shixiong Zhu <zsxwing@gmail.com> Signed-off-by: hyukjinkwon <gurwls223@apache.org>
This commit is contained in:
parent
2df34db586
commit
4b7f7ef500
|
@ -127,6 +127,7 @@ test_that("Specify a schema by using a DDL-formatted string when reading", {
|
||||||
expect_false(awaitTermination(q, 5 * 1000))
|
expect_false(awaitTermination(q, 5 * 1000))
|
||||||
callJMethod(q@ssq, "processAllAvailable")
|
callJMethod(q@ssq, "processAllAvailable")
|
||||||
expect_equal(head(sql("SELECT count(*) FROM people3"))[[1]], 3)
|
expect_equal(head(sql("SELECT count(*) FROM people3"))[[1]], 3)
|
||||||
|
stopQuery(q)
|
||||||
|
|
||||||
expect_error(read.stream(path = parquetPath, schema = "name stri"),
|
expect_error(read.stream(path = parquetPath, schema = "name stri"),
|
||||||
"DataType stri is not supported.")
|
"DataType stri is not supported.")
|
||||||
|
|
Loading…
Reference in a new issue