[beam] branch master updated: Increase streaming server timeout (#22280)

[da...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

damccorm 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 15c3c8fbb30 Increase streaming server timeout  (#22280)
15c3c8fbb30 is described below

commit 15c3c8fbb3058a50ce2949885a070089564add0c
Author: Byron Ellis <by...@gmail.com>
AuthorDate: Sun Jul 17 18:26:17 2022 -0700

    Increase streaming server timeout  (#22280)
    
    * Increase streaming server timeout to give tests a chance to complete before service teardown. Locally seems to help with Spark 2 tests
    
    * Try an insanely long timeout to see if the Spark Context dies or gets killed.
    
    Co-authored-by: Byron Ellis <by...@google.com>
---
 runners/spark/job-server/spark_job_server.gradle | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/runners/spark/job-server/spark_job_server.gradle b/runners/spark/job-server/spark_job_server.gradle
index d4bc26382ac..aa0434db83a 100644
--- a/runners/spark/job-server/spark_job_server.gradle
+++ b/runners/spark/job-server/spark_job_server.gradle
@@ -102,7 +102,7 @@ def portableValidatesRunnerTask(String name, boolean streaming, boolean docker,
   } else {
     if (streaming) {
       pipelineOptions += "--streaming"
-      pipelineOptions += "--streamingTimeoutMs=30000"
+      pipelineOptions += "--streamingTimeoutMs=120000"
 
       testCategories = {
         includeCategories 'org.apache.beam.sdk.testing.ValidatesRunner'