You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by bh...@apache.org on 2020/03/19 23:36:24 UTC
[beam] branch master updated: [BEAM-9552] Bump TestPubsub
subscription creation ACK deadline to 60s (#11169)
This is an automated email from the ASF dual-hosted git repository.
bhulette 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 8f1584d [BEAM-9552] Bump TestPubsub subscription creation ACK deadline to 60s (#11169)
8f1584d is described below
commit 8f1584dd73e3253f20bc75f25a81aaa68d9e6205
Author: Brian Hulette <bh...@google.com>
AuthorDate: Thu Mar 19 16:36:10 2020 -0700
[BEAM-9552] Bump TestPubsub subscription creation ACK deadline to 60s (#11169)
---
.../src/main/java/org/apache/beam/sdk/io/gcp/pubsub/TestPubsub.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/TestPubsub.java b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/TestPubsub.java
index e1e8711..4ea0b7b 100644
--- a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/TestPubsub.java
+++ b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/TestPubsub.java
@@ -60,6 +60,7 @@ public class TestPubsub implements TestRule {
private static final String TOPIC_PREFIX = "integ-test-";
private static final String NO_ID_ATTRIBUTE = null;
private static final String NO_TIMESTAMP_ATTRIBUTE = null;
+ private static final Integer DEFAULT_ACK_DEADLINE_SECONDS = 60;
private final TestPubsubOptions pipelineOptions;
@@ -121,7 +122,7 @@ public class TestPubsub implements TestRule {
pubsub.createRandomSubscription(
projectPathFromPath(String.format("projects/%s", pipelineOptions.getProject())),
topicPath(),
- 10);
+ DEFAULT_ACK_DEADLINE_SECONDS);
}
private void tearDown() throws IOException {