Flink Python API Bug

Question

i just tried out the flink python api. When i try:

env = get_environment()

I get:

IOError: [Errno 2] No such file or directory: '/tmp/flink_data/output'

The error is because of a path handling in:

flink-staging/flink-language-binding/flink-python/src/main/python/org/apache/flink/languagebinding/api/python/flink/connection/Connection.py    line 44

Instead of using:

open(tempfile.gettempdir() + "/flink_data/output", "rb+")

One could create the mapping file with:

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

The same applies for the mmap input file. Would that be a fix?

If there's a bug in third-party software you should report it to the developers. — jonrsharpe
– jonrsharpe, Commented Jun 17, 2015 at 16:52
I'm voting to close this question as off-topic because this belongs to the issue tracker of related software — Mikko Ohtamaa
– Mikko Ohtamaa, Commented Jun 17, 2015 at 17:48
The JIRA issues.apache.org/jira/browse/FLINK-2173 got resolved recently. If you are using Flink 0.10-SNAPSHOT you can try if your problem is resolved or not. — Matthias J. Sax
– Matthias J. Sax, Commented Aug 5, 2015 at 8:07

Matthias J. Sax · Accepted Answer · 2015-06-18 05:09:55Z

3

Please open a JIRA at https://issues.apache.org/jira/browse/FLINK/ Python API is quite new and still in beta state. There is another related JIRA, too: see https://issues.apache.org/jira/browse/FLINK-2173

Thanks for reporting the problem.

answered Jun 18, 2015 at 5:09

Matthias J. Sax

62.8k8 gold badges128 silver badges148 bronze badges

Sign up to request clarification or add additional context in comments.

Collectives™ on Stack Overflow

Flink Python API Bug

1 Answer 1

Comments

Your Answer

Hot Network Questions

Collectives™ on Stack Overflow

1 Answer 1

Comments

Your Answer

Sign up or log in

Post as a guest

Related