commit | b5f1ccc532a13bd90c941bfbe6697f04e307a2fb | [log] [tgz] |
---|---|---|
author | Daniel Collins <dpcollins@google.com> | Wed Sep 15 14:08:58 2021 -0400 |
committer | Daniel Collins <dpcollins@google.com> | Wed Sep 15 14:08:58 2021 -0400 |
tree | be25168667e6bb80f44923a8b3d08b97e48f78b5 | |
parent | f5afff17de0898bf0d2116e7757d89315f508cad [diff] |
[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())));