diff options
| author | Shixiong Zhu <shixiong@databricks.com> | 2017-04-19 13:10:44 -0700 |
|---|---|---|
| committer | Shixiong Zhu <shixiong@databricks.com> | 2017-04-19 13:10:44 -0700 |
| commit | 4fea7848c45d85ff3ad0863de5d1449d1fd1b4b0 (patch) | |
| tree | 93c7f45e17ad616539ef891df9313511bfd2b603 | |
| parent | 71a8e9df12e547cb4716f954ecb762b358f862d5 (diff) | |
| download | spark-4fea7848c45d85ff3ad0863de5d1449d1fd1b4b0.tar.gz spark-4fea7848c45d85ff3ad0863de5d1449d1fd1b4b0.tar.bz2 spark-4fea7848c45d85ff3ad0863de5d1449d1fd1b4b0.zip | |
[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.
| -rw-r--r-- | R/pkg/inst/tests/testthat/test_streaming.R | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/R/pkg/inst/tests/testthat/test_streaming.R b/R/pkg/inst/tests/testthat/test_streaming.R index 03b1bd3dc1..1f4054a84d 100644 --- a/R/pkg/inst/tests/testthat/test_streaming.R +++ b/R/pkg/inst/tests/testthat/test_streaming.R @@ -131,7 +131,7 @@ test_that("Terminated by error", { expect_error(q <- write.stream(counts, "memory", queryName = "people4", outputMode = "complete"), NA) - expect_error(awaitTermination(q, 1), + expect_error(awaitTermination(q, 5 * 1000), paste0(".*(awaitTermination : streaming query error - Invalid value '-1' for option", " 'maxFilesPerTrigger', must be a positive integer).*")) |