Flink Python API Bug

Question

i just tried out the flink python api. When i try:

env = get_environment()

I get:

IOError: [Errno 2] No such file or directory: '/tmp/flink_data/output'

The error is because of a path handling in:

flink-staging/flink-language-binding/flink-python/src/main/python/org/apache/flink/languagebinding/api/python/flink/connection/Connection.py    line 44 

Instead of using:

open(tempfile.gettempdir() + "/flink_data/output", "rb+")

One could create the mapping file with:

open(tempfile.gettempdir() + "/flinkoutput", "rb+")

The same applies for the mmap input file. Would that be a fix?

Answer 1

Please open a JIRA at https://issues.apache.org/jira/browse/FLINK/ Python API is quite new and still in beta state. There is another related JIRA, too: see https://issues.apache.org/jira/browse/FLINK-2173

Thanks for reporting the problem.