2
Я только что попробовал api flink python. Когда я попробовать:Flink Python API Bug
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+")
Можно создать mapp файл с:
open(tempfile.gettempdir() + "/flinkoutput", "rb+")
То же самое касается входного файла mmap. Будет ли это исправление?
Если у вас есть ошибка в стороннем программном обеспечении, вы должны сообщить об этом разработчикам. – jonrsharpe
Я голосую, чтобы закрыть этот вопрос как не относящийся к теме, потому что это относится к трекеру сопутствующего программного обеспечения. –
Недавно был разрешен JIRA https://issues.apache.org/jira/browse/FLINK-2173. Если вы используете Flink 0.10-SNAPSHOT, вы можете попробовать, если ваша проблема решена или нет. –