Re: Question about flink client

2017-03-27 Thread Till Rohrmann
sing files on HDFS. As a workround, I can config > `akka.lookup.timeout` to wait a bit longer, say 60 seconds. But I'm > wondering if it will affect other components." > > Thanks, > Yelei > > From: Till Rohrmann > Sent: Friday, March

Re: Question about flink client

2017-03-27 Thread Yelei Feng
quot; Thanks, Yelei From: Till Rohrmann Sent: Friday, March 24, 2017 8:09:29 AM To: dev@flink.apache.org Subject: Re: Question about flink client Hi Yelei, thanks for investigating the problem and pointing out the problematic parts. In fact, I recently stumbled across the very

Re: Question about flink client

2017-03-24 Thread Till Rohrmann
Hi Yelei, thanks for investigating the problem and pointing out the problematic parts. In fact, I recently stumbled across the very same problem in the JobClientActor and wrote a fix for it. It is already merged into the master. I hope that this fix solved the problem you've described. Cheers, Ti

Question about flink client

2017-03-22 Thread Yelei Feng
Hi, I have two questions about flink client in interactive mode. One is for yarn-session.sh, once the session CLI can't get cluster stauts (jobmanager is down), it will try to shutdown the cluster and cleanup related files even if new jobmanager will be created soon. As result, yarn will fa