python - Flink Python API バグ

Question

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 入力ファイルにも当てはまります。それは修正でしょうか？

Answer 1

https://issues.apache.org/jira/browse/FLINK/で JIRA を開いてください 。Python API は非常に新しく、まだベータ版の状態です。関連する別の JIRA もあります: https://issues.apache.org/jira/browse/FLINK-2173を参照してください。

問題を報告していただきありがとうございます。