[ https://issues.apache.org/jira/browse/FLINK-9927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Joe Malt updated FLINK-9927: ---------------------------- Comment: was deleted (was: I've made the change, the pull request is here: https://github.com/apache/flink/pull/6424) > Error in Python Stream API example on website > --------------------------------------------- > > Key: FLINK-9927 > URL: https://issues.apache.org/jira/browse/FLINK-9927 > Project: Flink > Issue Type: Bug > Components: Documentation > Affects Versions: 1.6.0 > Reporter: Joe Malt > Priority: Minor > Labels: pull-request-available > > The [Python Programming Guide (Streaming) > |https://ci.apache.org/projects/flink/flink-docs-master/dev/stream/python.html#program-skeleton]page > contains a WordCount example with the following main method: > {code:java} > def main(factory): > env = factory.get_execution_environment() > env.create_python_source(Generator(num_iters=1000)) \ > .flat_map(Tokenizer()) \ > .key_by(Selector()) \ > .time_window(milliseconds(50)) \ > .reduce(Sum()) \ > .print(){code} > The print() should, [according to the documentation, be > output()|https://ci.apache.org/projects/flink/flink-docs-release-1.6/api/java/org/apache/flink/streaming/python/api/datastream/PythonDataStream.html#output%E2%80%93]. > Trying to call print() results in an error: > {code:java} > jmalt-machine:bin jmalt$ ./pyflink-stream.sh > /Users/jmalt/flink-python/WordCount.py > Starting execution of program > Failed to run plan: null > Traceback (most recent call last): > File "<string>", line 1, in <module> > File > "/var/folders/t1/gcltcjcn5zdgqfqrc32xk90x85xkg9/T/flink_streaming_plan_9539e241-ba0a-42bf-9d4c-844dda26b998/WordCount.py", > line 43, in main > AttributeError: 'org.apache.flink.streaming.python.api.datastream.P' object > has no attribute 'print'{code} -- This message was sent by Atlassian JIRA (v7.6.3#76005)