You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@flink.apache.org by Timothy Victor <vi...@gmail.com> on 2019/05/24 13:47:46 UTC

Job crashing cluster

If a flink job crashes during startup (throws exception) the entire cluster
goes down.   This is even on a simple bare metal host.


I have tried catching the exception, but even that didnt prevent the JM and
cluster from crashing.

Has anyone run into this problem?

I'm on Flink 1.7.1

Thanks

Tim

Re: Job crashing cluster

Posted by Timothy Victor <vi...@gmail.com>.

Thanks for the reply Sushant.  I think this was a dumb error on my part.
Even though I was catching the exception in main, I was calling sys.exit
(as I would normally in a standalone app) and this was causing JM to exit.

Tim

On Fri, May 24, 2019, 1:29 PM Sushant Sawant <su...@gmail.com>
wrote:

> Hi,
> Could you share error stack trace?
>
> Thanks & Regards,
> Sushant Sawant
>
>
> On Fri, 24 May 2019, 19:18 Timothy Victor, <vi...@gmail.com> wrote:
>
>> If a flink job crashes during startup (throws exception) the entire
>> cluster goes down.   This is even on a simple bare metal host.
>>
>>
>> I have tried catching the exception, but even that didnt prevent the JM
>> and cluster from crashing.
>>
>> Has anyone run into this problem?
>>
>> I'm on Flink 1.7.1
>>
>> Thanks
>>
>> Tim
>>
>

Re: Job crashing cluster

Posted by Sushant Sawant <su...@gmail.com>.

Hi,
Could you share error stack trace?

Thanks & Regards,
Sushant Sawant


On Fri, 24 May 2019, 19:18 Timothy Victor, <vi...@gmail.com> wrote:

> If a flink job crashes during startup (throws exception) the entire
> cluster goes down.   This is even on a simple bare metal host.
>
>
> I have tried catching the exception, but even that didnt prevent the JM
> and cluster from crashing.
>
> Has anyone run into this problem?
>
> I'm on Flink 1.7.1
>
> Thanks
>
> Tim
>