| commit | 3a3933caa1cdb11e6584bce87f8494979ab95cb1 | [log] [tgz] |
|---|---|---|
| author | Kyle Weaver <kcweaver@google.com> | Wed Sep 15 14:47:09 2021 -0700 |
| committer | GitHub <noreply@github.com> | Wed Sep 15 14:47:09 2021 -0700 |
| tree | cdc236e8b1abbf9774ebfacf2bb9bb9ba12b79ca | |
| parent | d46cd9eae3bc1a4345f023230bdf135d2b2f0f68 [diff] | |
| parent | b5f1ccc532a13bd90c941bfbe6697f04e307a2fb [diff] |
Merge pull request #15515 from dpcollins-google/fix-jenkins-only-failure [BEAM-12882] - fix test that is flaky when jenkins is overloaded
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 @@ }) .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())));