[beam] branch master updated: [BEAM-12882] - fix test that is flaky when jenkins is overloaded

[ibzib]

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 b5f1ccc  [BEAM-12882] - fix test that is flaky when jenkins is 
overloaded
     new 3a3933c  Merge pull request #15515 from 
dpcollins-google/fix-jenkins-only-failure
b5f1ccc is described below

commit b5f1ccc532a13bd90c941bfbe6697f04e307a2fb
Author: Daniel Collins <dpcoll...@google.com>
AuthorDate: Wed Sep 15 14:08:58 2021 -0400

    [BEAM-12882] - fix test that is flaky when jenkins is overloaded
---
 .../beam/sdk/io/gcp/pubsublite/SubscriptionPartitionLoader.java       | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)

diff --git 
a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/SubscriptionPartitionLoader.java
 
b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/SubscriptionPartitionLoader.java
index e411d80..866e922 100644
--- 
a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/SubscriptionPartitionLoader.java
+++ 
b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/SubscriptionPartitionLoader.java
@@ -92,9 +92,7 @@ class SubscriptionPartitionLoader extends PTransform<PBegin, 
PCollection<Subscri
                     })
                 .withPollInterval(pollDuration)
                 .withTerminationPerInput(
-                    terminate
-                        ? 
Watch.Growth.afterTotalOf(pollDuration.multipliedBy(10))
-                        : Watch.Growth.never()));
+                    terminate ? Watch.Growth.afterIterations(10) : 
Watch.Growth.never()));
     return partitions.apply(
         MapElements.into(TypeDescriptor.of(SubscriptionPartition.class))
             .via(kv -> SubscriptionPartition.of(subscription, kv.getValue())));