Flink Python API 错误答案

【问题标题】：Flink Python API BugFlink Python API 错误
【发布时间】：2015-06-17 16:49:16
【问题描述】：

我刚刚试用了 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 输入文件。这样可以解决吗？

【问题讨论】：

如果第三方软件有错误，您应该向开发人员报告。
我投票结束这个问题，因为它属于相关软件的问题跟踪器
JIRA issues.apache.org/jira/browse/FLINK-2173 最近得到了解决。如果您使用的是 Flink 0.10-SNAPSHOT，您可以尝试一下您的问题是否已解决。
@MatthiasJ.Sax，很酷，很快就会尝试 :-)

标签： python apache-flink

【解决方案1】：

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

感谢您报告问题。

【讨论】：