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/12/29 23:43:16 UTC
[beam] branch master updated: [BEAM-11537] Fix
TestPubSubSignal.waitForStart (#13632)
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 4827bea [BEAM-11537] Fix TestPubSubSignal.waitForStart (#13632)
4827bea is described below
commit 4827bea3c484ed6baebc77c4eaba067117dd5efd
Author: Brian Hulette <bh...@google.com>
AuthorDate: Tue Dec 29 15:42:38 2020 -0800
[BEAM-11537] Fix TestPubSubSignal.waitForStart (#13632)
---
.../main/java/org/apache/beam/sdk/io/gcp/pubsub/TestPubsubSignal.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/TestPubsubSignal.java b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/TestPubsubSignal.java
index 86f80ef..d0753cc 100644
--- a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/TestPubsubSignal.java
+++ b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/TestPubsubSignal.java
@@ -249,8 +249,8 @@ public class TestPubsubSignal implements TestRule {
"start-subscription-" + String.valueOf(ThreadLocalRandom.current().nextLong()));
subscriptionAdmin.createSubscription(
- startTopicPath.getPath(),
startSubscriptionPath.getPath(),
+ startTopicPath.getPath(),
PushConfig.getDefaultInstance(),
(int) duration.getStandardSeconds());