Hi

I think you could still use ./bin/flink cancel <jobID> to cancel the job. What 
is the exception thrown?

Best
Yun Tang
________________________________
From: seeksst <seek...@163.com>
Sent: Wednesday, April 22, 2020 18:17
To: user <user@flink.apache.org>
Subject: Flink 1.10.0 stop command


Hi,


   When i test 1.10.0, i found i must to set savepoint path otherwise i can’t 
stop the job. I confuse about this, beacuse as i know, savepoint offen large 
than checkpoint, so i usually resume job from checkpoint. Another problem is 
sometimes job throw exception and i can’t trigger a savepoint, so i cancel the 
job and change logical, resume it from last checkpoint. although sometimes will 
failed, i think this will be a better way, because i can choose cancel with a 
savepoint or not, so i can decede how to resume. but in 1.10.0, i must to set 
it, and seems system will trigger savepoint, i think this will take more risk, 
and it will delete checkpoint even i set retain on cancellation. so i have no 
checkpoint left. If i use cancel <jobID>, it will break with exception.

So how to work with 1.10.0 ? any advice will be helpful.

  Thanks.


Reply via email to