yarn commit problem

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

yarn commit problem

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!

Reply | Threaded
Open this post in threaded view
|

Re: yarn commit problem

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, lining jing <[hidden email]> wrote:
>
> 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!
>