Repository: spark Updated Branches: refs/heads/master 2df34db58 -> 4b7f7ef50
[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 <zsxw...@gmail.com> Signed-off-by: hyukjinkwon <gurwls...@apache.org> Project: http://git-wip-us.apache.org/repos/asf/spark/repo Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/4b7f7ef5 Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/4b7f7ef5 Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/4b7f7ef5 Branch: refs/heads/master Commit: 4b7f7ef5007c2c8a5090f22c6e08927e9f9a407b Parents: 2df34db Author: Shixiong Zhu <zsxw...@gmail.com> Authored: Wed Nov 21 09:31:12 2018 +0800 Committer: hyukjinkwon <gurwls...@apache.org> Committed: Wed Nov 21 09:31:12 2018 +0800 ---------------------------------------------------------------------- R/pkg/tests/fulltests/test_streaming.R | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/spark/blob/4b7f7ef5/R/pkg/tests/fulltests/test_streaming.R ---------------------------------------------------------------------- diff --git a/R/pkg/tests/fulltests/test_streaming.R b/R/pkg/tests/fulltests/test_streaming.R index bfb1a04..6f0d2ae 100644 --- a/R/pkg/tests/fulltests/test_streaming.R +++ b/R/pkg/tests/fulltests/test_streaming.R @@ -127,6 +127,7 @@ test_that("Specify a schema by using a DDL-formatted string when reading", { expect_false(awaitTermination(q, 5 * 1000)) callJMethod(q@ssq, "processAllAvailable") expect_equal(head(sql("SELECT count(*) FROM people3"))[[1]], 3) + stopQuery(q) expect_error(read.stream(path = parquetPath, schema = "name stri"), "DataType stri is not supported.") --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@spark.apache.org For additional commands, e-mail: commits-h...@spark.apache.org
