[ https://issues.apache.org/jira/browse/BEAM-1545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15883127#comment-15883127 ]
Ahmet Altay commented on BEAM-1545: ----------------------------------- >From quickstart - I can reproduce the wordcount error. You can workaround for now by changing the pip install step: pip install apache-beam-sdk-*.tar.gz .[gcp] - I cannot reproduce the error with python setup.py test. Could you share more information on that? What packages you have installed on your virtualenv (pip list), and what is your environment? > Python sdk example run failed > ----------------------------- > > Key: BEAM-1545 > URL: https://issues.apache.org/jira/browse/BEAM-1545 > Project: Beam > Issue Type: Bug > Components: sdk-py > Reporter: Haoxiang > Assignee: Sourabh Bajaj > > When I run the python sdk example with > https://beam.apache.org/get-started/quickstart-py/ show, run the command: > python -m apache_beam.examples.wordcount --input > gs://dataflow-samples/shakespeare/kinglear.txt --output output.txt > it was failed by the logs: > INFO:root:Missing pipeline option (runner). Executing pipeline using the > default runner: DirectRunner. > Traceback (most recent call last): > File > "/usr/local/Cellar/python/2.7.11/Frameworks/Python.framework/Versions/2.7/lib/python2.7/runpy.py", > line 162, in _run_module_as_main > "__main__", fname, loader, pkg_name) > File > "/usr/local/Cellar/python/2.7.11/Frameworks/Python.framework/Versions/2.7/lib/python2.7/runpy.py", > line 72, in _run_code > exec code in run_globals > File > "/Users/haoxiang/InterestingGitProject/beam/sdks/python/apache_beam/examples/wordcount.py", > line 107, in <module> > run() > File > "/Users/haoxiang/InterestingGitProject/beam/sdks/python/apache_beam/examples/wordcount.py", > line 83, in run > lines = p | 'read' >> ReadFromText(known_args.input) > File "apache_beam/io/textio.py", line 378, in __init__ > skip_header_lines=skip_header_lines) > File "apache_beam/io/textio.py", line 87, in __init__ > validate=validate) > File "apache_beam/io/filebasedsource.py", line 97, in __init__ > self._validate() > File "apache_beam/io/filebasedsource.py", line 171, in _validate > if len(fileio.ChannelFactory.glob(self._pattern, limit=1)) <= 0: > File "apache_beam/io/fileio.py", line 281, in glob > return gcsio.GcsIO().glob(path, limit) > AttributeError: 'NoneType' object has no attribute 'GcsIO' -- This message was sent by Atlassian JIRA (v6.3.15#6346)