flink python api错误

bsxbgnwa  于 2021-06-24  发布在  Flink
关注(0)|答案(1)|浏览(261)

我刚刚试用了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+")

可以使用以下内容创建Map文件:

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

这同样适用于mmap输入文件。那会是个解决办法吗?

iswrvxsc

iswrvxsc1#

请在门口开一个吉拉https://issues.apache.org/jira/browse/flink/ pythonapi是一个非常新的测试版。还有另一个相关的吉拉:看https://issues.apache.org/jira/browse/flink-2173
谢谢你报告这个问题。

相关问题