git.net

[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

Re: Portable pipelines on Flink


On Wed, Jul 4, 2018 at 1:06 AM Thomas Weise <thw@xxxxxxxxxx> wrote:
[subject change for discussion fork]

Thanks for the steps. I'm able to run the Python wordcount example, though it fails with local file output. Did you test with distributed FS or local FS?

It doesn't work with local FS because the code running in docker doesn't have access to the local FS. It would be good to automatically support this somehow (with mount points?) but exactly what to do here is non-trivial.