You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@flink.apache.org by Vishal Santoshi <vi...@gmail.com> on 2018/07/06 20:53:35 UTC
flink1.5 web UI
If we submit a job through CLI and it has an error ( missing args and so on
) , the JM goes into convulsions. It seems it submits a job without fist
validating and then goes into a loop trying to figure out the job
Jul 06 16:51:26 flink-9edd15d7.bf2.tumblr.net docker[31171]: at
scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
Jul 06 16:51:26 flink-9edd15d7.bf2.tumblr.net docker[31171]: at
scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
Jul 06 16:51:26 flink-9edd15d7.bf2.tumblr.net docker[31171]: Caused by:
org.apache.flink.runtime.messages.FlinkJobNotFoundException: Could not find
Flink job (0de3cb47d32dd25ba0375d97bfd07387)
Jul 06 16:51:26 flink-9edd15d7.bf2.tumblr.net docker[31171]: at
org.apache.flink.runtime.dispatcher.Dispatcher.getJobMasterGatewayFuture(Dispatcher.java:693)
Jul 06 16:51:26 flink-9edd15d7.bf2.tumblr.net docker[31171]: at
org.apache.flink.runtime.dispatcher.Dispatcher.requestJob(Dispatcher.java:459)
Jul 06 16:51:26 flink-9edd15d7.bf2.tumblr.net docker[31171]: at
sun.reflect.GeneratedMethodAccessor48.invoke(Unknown Source)
Is this known ?
Re: flink1.5 web UI
Posted by Till Rohrmann <tr...@apache.org>.
This happens usually if you have an old tab open for a job which has been
finished and is not archived. Then you cluster won't find this job anymore.
Cheers,
Till
On Fri, Jul 6, 2018 at 11:11 PM Vishal Santoshi <vi...@gmail.com>
wrote:
> It seems it is the UI refresh that forces the loop on the job server.
> From flink cli it does it once.. So this might be a false alarm.
>
> On Fri, Jul 6, 2018 at 4:55 PM, Vishal Santoshi <vishal.santoshi@gmail.com
> > wrote:
>
>> The UI shows the following and the JM goes into a convulsions trying to
>> retrieve a jobiid as above.
>>
>> org.apache.flink.client.program.ProgramInvocationException: The main method caused an error.
>>
>>
>> On Fri, Jul 6, 2018 at 4:53 PM, Vishal Santoshi <
>> vishal.santoshi@gmail.com> wrote:
>>
>>> If we submit a job through CLI and it has an error ( missing args and so
>>> on ) , the JM goes into convulsions. It seems it submits a job without fist
>>> validating and then goes into a loop trying to figure out the job
>>>
>>> Jul 06 16:51:26 flink-9edd15d7.bf2.tumblr.net docker[31171]: at
>>> scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
>>>
>>> Jul 06 16:51:26 flink-9edd15d7.bf2.tumblr.net docker[31171]: at
>>> scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
>>>
>>> Jul 06 16:51:26 flink-9edd15d7.bf2.tumblr.net docker[31171]: Caused by:
>>> org.apache.flink.runtime.messages.FlinkJobNotFoundException: Could not find
>>> Flink job (0de3cb47d32dd25ba0375d97bfd07387)
>>>
>>> Jul 06 16:51:26 flink-9edd15d7.bf2.tumblr.net docker[31171]: at
>>> org.apache.flink.runtime.dispatcher.Dispatcher.getJobMasterGatewayFuture(Dispatcher.java:693)
>>>
>>> Jul 06 16:51:26 flink-9edd15d7.bf2.tumblr.net docker[31171]: at
>>> org.apache.flink.runtime.dispatcher.Dispatcher.requestJob(Dispatcher.java:459)
>>>
>>> Jul 06 16:51:26 flink-9edd15d7.bf2.tumblr.net docker[31171]: at
>>> sun.reflect.GeneratedMethodAccessor48.invoke(Unknown Source)
>>>
>>> Is this known ?
>>>
>>
>>
>
Re: flink1.5 web UI
Posted by Vishal Santoshi <vi...@gmail.com>.
It seems it is the UI refresh that forces the loop on the job server. From
flink cli it does it once.. So this might be a false alarm.
On Fri, Jul 6, 2018 at 4:55 PM, Vishal Santoshi <vi...@gmail.com>
wrote:
> The UI shows the following and the JM goes into a convulsions trying to
> retrieve a jobiid as above.
>
> org.apache.flink.client.program.ProgramInvocationException: The main method caused an error.
>
>
> On Fri, Jul 6, 2018 at 4:53 PM, Vishal Santoshi <vishal.santoshi@gmail.com
> > wrote:
>
>> If we submit a job through CLI and it has an error ( missing args and so
>> on ) , the JM goes into convulsions. It seems it submits a job without fist
>> validating and then goes into a loop trying to figure out the job
>>
>> Jul 06 16:51:26 flink-9edd15d7.bf2.tumblr.net docker[31171]: at
>> scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
>>
>> Jul 06 16:51:26 flink-9edd15d7.bf2.tumblr.net docker[31171]: at
>> scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinW
>> orkerThread.java:107)
>>
>> Jul 06 16:51:26 flink-9edd15d7.bf2.tumblr.net docker[31171]: Caused by:
>> org.apache.flink.runtime.messages.FlinkJobNotFoundException: Could not
>> find Flink job (0de3cb47d32dd25ba0375d97bfd07387)
>>
>> Jul 06 16:51:26 flink-9edd15d7.bf2.tumblr.net docker[31171]: at
>> org.apache.flink.runtime.dispatcher.Dispatcher.getJobMasterG
>> atewayFuture(Dispatcher.java:693)
>>
>> Jul 06 16:51:26 flink-9edd15d7.bf2.tumblr.net docker[31171]: at
>> org.apache.flink.runtime.dispatcher.Dispatcher.requestJob(
>> Dispatcher.java:459)
>>
>> Jul 06 16:51:26 flink-9edd15d7.bf2.tumblr.net docker[31171]: at
>> sun.reflect.GeneratedMethodAccessor48.invoke(Unknown Source)
>>
>> Is this known ?
>>
>
>
Re: flink1.5 web UI
Posted by Vishal Santoshi <vi...@gmail.com>.
The UI shows the following and the JM goes into a convulsions trying to
retrieve a jobiid as above.
org.apache.flink.client.program.ProgramInvocationException: The main
method caused an error.
On Fri, Jul 6, 2018 at 4:53 PM, Vishal Santoshi <vi...@gmail.com>
wrote:
> If we submit a job through CLI and it has an error ( missing args and so
> on ) , the JM goes into convulsions. It seems it submits a job without fist
> validating and then goes into a loop trying to figure out the job
>
> Jul 06 16:51:26 flink-9edd15d7.bf2.tumblr.net docker[31171]: at
> scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
>
> Jul 06 16:51:26 flink-9edd15d7.bf2.tumblr.net docker[31171]: at
> scala.concurrent.forkjoin.ForkJoinWorkerThread.run(
> ForkJoinWorkerThread.java:107)
>
> Jul 06 16:51:26 flink-9edd15d7.bf2.tumblr.net docker[31171]: Caused by:
> org.apache.flink.runtime.messages.FlinkJobNotFoundException: Could not
> find Flink job (0de3cb47d32dd25ba0375d97bfd07387)
>
> Jul 06 16:51:26 flink-9edd15d7.bf2.tumblr.net docker[31171]: at
> org.apache.flink.runtime.dispatcher.Dispatcher.getJobMasterGatewayFuture(
> Dispatcher.java:693)
>
> Jul 06 16:51:26 flink-9edd15d7.bf2.tumblr.net docker[31171]: at
> org.apache.flink.runtime.dispatcher.Dispatcher.requestJob(Dispatcher.java:
> 459)
>
> Jul 06 16:51:26 flink-9edd15d7.bf2.tumblr.net docker[31171]: at
> sun.reflect.GeneratedMethodAccessor48.invoke(Unknown Source)
>
> Is this known ?
>