You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by al...@apache.org on 2019/09/07 01:48:30 UTC

[beam] branch master updated: Fix typo in Cloud Pub/Sub topic path

This is an automated email from the ASF dual-hosted git repository.

altay 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 7f64067  Fix typo in Cloud Pub/Sub topic path
     new 4b94239  Merge pull request #9500 from anguillanneuf/patch-1
7f64067 is described below

commit 7f64067611b660766f96101779ea987c958d639a
Author: Tianzi Cai <ti...@outlook.com>
AuthorDate: Fri Sep 6 11:55:12 2019 -0700

    Fix typo in Cloud Pub/Sub topic path
---
 sdks/python/apache_beam/examples/streaming_wordcount.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/sdks/python/apache_beam/examples/streaming_wordcount.py b/sdks/python/apache_beam/examples/streaming_wordcount.py
index d1ecc63..c9f122b 100644
--- a/sdks/python/apache_beam/examples/streaming_wordcount.py
+++ b/sdks/python/apache_beam/examples/streaming_wordcount.py
@@ -39,7 +39,7 @@ def run(argv=None):
   parser.add_argument(
       '--output_topic', required=True,
       help=('Output PubSub topic of the form '
-            '"projects/<PROJECT>/topic/<TOPIC>".'))
+            '"projects/<PROJECT>/topics/<TOPIC>".'))
   group = parser.add_mutually_exclusive_group(required=True)
   group.add_argument(
       '--input_topic',