Skip to content

Commit 4fea784

Browse files
committed
[SPARK-20397][SPARKR][SS] Fix flaky test: test_streaming.R.Terminated by error
## What changes were proposed in this pull request? Checking a source parameter is asynchronous. When the query is created, it's not guaranteed that source has been created. This PR just increases the timeout of awaitTermination to ensure the parsing error is thrown. ## How was this patch tested? Jenkins Author: Shixiong Zhu <[email protected]> Closes #17687 from zsxwing/SPARK-20397.
1 parent 71a8e9d commit 4fea784

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

R/pkg/inst/tests/testthat/test_streaming.R

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -131,7 +131,7 @@ test_that("Terminated by error", {
131131
expect_error(q <- write.stream(counts, "memory", queryName = "people4", outputMode = "complete"),
132132
NA)
133133

134-
expect_error(awaitTermination(q, 1),
134+
expect_error(awaitTermination(q, 5 * 1000),
135135
paste0(".*(awaitTermination : streaming query error - Invalid value '-1' for option",
136136
" 'maxFilesPerTrigger', must be a positive integer).*"))
137137

0 commit comments

Comments
 (0)