我刚刚试用了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输入文件。那会是个解决办法吗?
1条答案
按热度按时间iswrvxsc1#
请在门口开一个吉拉https://issues.apache.org/jira/browse/flink/ pythonapi是一个非常新的测试版。还有另一个相关的吉拉:看https://issues.apache.org/jira/browse/flink-2173
谢谢你报告这个问题。