Flink Python API错误

Question

我刚试用了FlinkPythonAPI。 当我尝试：

env = get_environment()

我得到：

^{pr2}$

错误是由于中的路径处理：

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

请在https://issues.apache.org/jira/browse/FLINK/打开一个JIRA pythonapi是相当新的，仍然处于beta状态。还有另一个相关的JIRA：参见https://issues.apache.org/jira/browse/FLINK-2173

感谢您报告问题。在