beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bhule...@apache.org
Subject [beam] branch master updated: [BEAM-11537] Fix TestPubSubSignal.waitForStart (#13632)
Date Tue, 29 Dec 2020 23:43:16 GMT
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 <bhulette@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());
 


Mime
View raw message