Joe Malt created FLINK-9927: ------------------------------- Summary: 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
The _Python Programming Guide (Streaming)_ 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–]. 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)