Job crashing cluster

[Timothy Victor]

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

[Sushant Sawant]

Hi, 

Could you share error stack trace?

Thanks & Regards,

Sushant Sawant

On Fri, 24 May 2019, 19:18 Timothy Victor, <[hidden email]> 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

[Timothy Victor]

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 <[hidden email]> wrote:

Hi, 

Could you share error stack trace?

Thanks & Regards,

Sushant Sawant

On Fri, 24 May 2019, 19:18 Timothy Victor, <[hidden email]> 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