Re: yarn commit problem

2017-05-31 Thread Aljoscha Krettek
Hi, I tried to reproduce this but I could successfully run an example streaming program on a YARN cluster with the -d flag. What version of Flink are you using? Could you maybe post some code so that we might try and understand the problem better? Best, Aljoscha > On 5. May 2017, at 10:23, lin

yarn commit problem

2017-05-05 Thread lining jing
Hi All! if I commit job on yarn with -d will show exception Caused by: java.lang.IllegalStateException: No operators defined in streaming topology. Cannot execute. If I delete -d will ok Can someone tell me Why? thanks!