[beam] branch master updated: Fix topic URIs.

[al...@apache.org]

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 3898ba4  Fix topic URIs.
     new 9eca13c  This closes #4250
3898ba4 is described below

commit 3898ba45a2ffe059ee80271040baedac4ba3aaa0
Author: postmasters <na...@google.com>
AuthorDate: Tue Dec 12 13:56:50 2017 -0800

    Fix topic URIs.
---
 sdks/python/apache_beam/examples/streaming_wordcap.py | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/sdks/python/apache_beam/examples/streaming_wordcap.py b/sdks/python/apache_beam/examples/streaming_wordcap.py
index 19f9e5f..01e0df2 100644
--- a/sdks/python/apache_beam/examples/streaming_wordcap.py
+++ b/sdks/python/apache_beam/examples/streaming_wordcap.py
@@ -35,10 +35,10 @@ def run(argv=None):
   parser = argparse.ArgumentParser()
   parser.add_argument(
       '--input_topic', dest='input_topic', required=True,
-      help='Input PubSub topic of the form "/topics/<PROJECT>/<TOPIC>".')
+      help='Input PubSub topic with form "projects/<PROJECT>/topics/<TOPIC>".')
   parser.add_argument(
       '--output_topic', dest='output_topic', required=True,
-      help='Output PubSub topic of the form "/topics/<PROJECT>/<TOPIC>".')
+      help='Output PubSub topic with form "projects/<PROJECT>/topics/<TOPIC>".')
   known_args, pipeline_args = parser.parse_known_args(argv)
 
   with beam.Pipeline(argv=pipeline_args) as p:

-- 
To stop receiving notification emails like this one, please contact
altay@apache.org.