This is an automated email from the ASF dual-hosted git repository.
ibzib pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push:
new 923b823 [BEAM-10460] Increase
SparkPortableExecutionTest.testExecution timeout to 10 minutes
new e7f2589 Merge pull request #12243 from
kennknowles/SparkPortableExecutionTest
923b823 is described below
commit 923b8239b433c446ef4f9dfb04dd5d6e3356ea71
Author: Kenneth Knowles <[email protected]>
AuthorDate: Mon Jul 13 14:37:06 2020 -0700
[BEAM-10460] Increase SparkPortableExecutionTest.testExecution timeout to
10 minutes
Successful runs have been seen at 90 seconds. The timeout only needs to
catch
deadlocks and crashloops and should not be sensitive to performance in
either
the underlying code or our test infrastructure.
---
.../java/org/apache/beam/runners/spark/SparkPortableExecutionTest.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/runners/spark/src/test/java/org/apache/beam/runners/spark/SparkPortableExecutionTest.java
b/runners/spark/src/test/java/org/apache/beam/runners/spark/SparkPortableExecutionTest.java
index 1406446..f5b8137 100644
---
a/runners/spark/src/test/java/org/apache/beam/runners/spark/SparkPortableExecutionTest.java
+++
b/runners/spark/src/test/java/org/apache/beam/runners/spark/SparkPortableExecutionTest.java
@@ -78,7 +78,7 @@ public class SparkPortableExecutionTest implements
Serializable {
sparkJobExecutor = null;
}
- @Test(timeout = 120_000)
+ @Test(timeout = 600_000)
public void testExecution() throws Exception {
PipelineOptions options =
PipelineOptionsFactory.fromArgs("--experiments=beam_fn_api").create();
options.setRunner(CrashingRunner.class);