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',