Re: Portable pipelines on Flink

2018-07-06 Thread Thomas Weise
On Wed, Jul 4, 2018 at 10:06 AM Thomas Weise wrote: > * The gradle task to run job server takes really long to start the server > (> 1 minute on my macbook). Every restart appears to occur the same > penalty, regardless of whether there are changes or not. Following can be > used to just start th

Re: Portable pipelines on Flink

2018-07-06 Thread Robert Bradshaw
On Wed, Jul 4, 2018 at 1:06 AM Thomas Weise 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

Re: Portable pipelines on Flink

2018-07-04 Thread Thomas Weise
> > > > * Job server does not currently provide log output. > It is currently configured with the simple logger backend, so to get console output just add -Dorg.slf4j.simpleLogger.defaultLogLevel=debug to the command line.

Portable pipelines on Flink

2018-07-04 Thread Thomas Weise
[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? Some more observations so far: * Job server does not currently provide log output. * The gradle task to r