Skip to content

Commit d649787

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 <shixiong@databricks.com> Closes #17687 from zsxwing/SPARK-20397. (cherry picked from commit 4fea784) Signed-off-by: Shixiong Zhu <shixiong@databricks.com>
1 parent 80a60da commit d649787

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)