python - Flink Python API 错误

Question

我刚刚尝试了 flink python api。 当我尝试时:

env = get_environment()

我得到:

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

该错误是由于以下位置的路径处理造成的:

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

而不是使用:

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

可以使用以下命令创建映射文件:

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

这同样适用于 mmap 输入文件。 这能解决问题吗？

Answer 1

请打开 JIRA https://issues.apache.org/jira/browse/FLINK/ Python API 相当新，仍处于测试状态。还有另一个相关的 JIRA:参见 https://issues.apache.org/jira/browse/FLINK-2173

感谢您报告问题。