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