[beam] branch master updated: [BEAM-10040, BEAM-6804] Increase wait times to reduce flakiness. Currently a lot of these tests take ~30 seconds on my machine which means that it is likely to flake since the timeout is on the same order of magnitude as the current test.

[lc...@apache.org]

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

lcwik 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 7099356  [BEAM-10040, BEAM-6804] Increase wait times to reduce flakiness. Currently a lot of these tests take ~30 seconds on my machine which means that it is likely to flake since the timeout is on the same order of magnitude as the current test.
     new 0d362dd  Merge pull request #12622 from lukecwik/beam6804
7099356 is described below

commit 7099356a97adc9c203fcb283040a15684791d9ae
Author: Luke Cwik <lc...@google.com>
AuthorDate: Tue Aug 18 15:25:08 2020 -0700

    [BEAM-10040, BEAM-6804] Increase wait times to reduce flakiness. Currently a lot of these tests take ~30 seconds on my machine which means that it is likely to flake since the timeout is on the same order of magnitude as the current test.
---
 .../test/java/org/apache/beam/sdk/io/gcp/healthcare/FhirIOReadIT.java | 2 +-
 .../src/test/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubReadIT.java | 4 ++--
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/healthcare/FhirIOReadIT.java b/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/healthcare/FhirIOReadIT.java
index b434f68..38c310e 100644
--- a/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/healthcare/FhirIOReadIT.java
+++ b/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/healthcare/FhirIOReadIT.java
@@ -137,7 +137,7 @@ public class FhirIOReadIT {
     pipeline.apply(signal.signalStart());
     PipelineResult job = pipeline.run();
     start.get();
-    signal.waitForSuccess(Duration.standardSeconds(30));
+    signal.waitForSuccess(Duration.standardMinutes(5));
 
     // A runner may not support cancel
     try {
diff --git a/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubReadIT.java b/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubReadIT.java
index 9856606..fa05679 100644
--- a/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubReadIT.java
+++ b/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubReadIT.java
@@ -59,7 +59,7 @@ public class PubsubReadIT {
     PipelineResult job = pipeline.run();
     start.get();
 
-    signal.waitForSuccess(Duration.standardSeconds(30));
+    signal.waitForSuccess(Duration.standardMinutes(5));
     // A runner may not support cancel
     try {
       job.cancel();
@@ -87,7 +87,7 @@ public class PubsubReadIT {
     PipelineResult job = pipeline.run();
     start.get();
 
-    signal.waitForSuccess(Duration.standardMinutes(1));
+    signal.waitForSuccess(Duration.standardMinutes(5));
     // A runner may not support cancel
     try {
       job.cancel();