Skip to content

Commit d8e05d2

Browse files
zsxwingHyukjinKwon
authored andcommitted
[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> (cherry picked from commit 4b7f7ef) Signed-off-by: hyukjinkwon <gurwls223@apache.org>
1 parent 3bb9fff commit d8e05d2

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

R/pkg/tests/fulltests/test_streaming.R

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -127,6 +127,7 @@ test_that("Specify a schema by using a DDL-formatted string when reading", {
127127
expect_false(awaitTermination(q, 5 * 1000))
128128
callJMethod(q@ssq, "processAllAvailable")
129129
expect_equal(head(sql("SELECT count(*) FROM people3"))[[1]], 3)
130+
stopQuery(q)
130131

131132
expect_error(read.stream(path = parquetPath, schema = "name stri"),
132133
"DataType stri is not supported.")

0 commit comments

Comments
 (0)