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())));