2

我刚刚试用了 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 输入文件。那会是一个修复吗?

4

1 回答 1

3

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

感谢您报告问题。

于 2015-06-18T05:09:55.077 回答