You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@flink.apache.org by seeksst <se...@163.com> on 2020/04/22 10:17:26 UTC
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 usecancel jobID, it will break with exception.
So how to work with 1.10.0 ? any advice will be helpful.
Thanks.
Re: Flink 1.10.0 stop command
Posted by tison <wa...@gmail.com>.
To be precise, the cancel command would succeed on cluster side but the
response *might* lost so that client throws with TimeoutException. If it is
the case, this is the root which will be fixed in 1.10.1.
Best,
tison.
tison <wa...@gmail.com> 于2020年4月23日周四 上午1:20写道：
> 'flink cancel' broken because of
> https://issues.apache.org/jira/browse/FLINK-16626
>
> Best,
> tison.
>
>
> Yun Tang <my...@live.com> 于2020年4月23日周四 上午1:18写道：
>
>> 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 <se...@163.com>
>> *Sent:* Wednesday, April 22, 2020 18:17
>> *To:* user <us...@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.
>>
>>
>>
>
Re: Flink 1.10.0 stop command
Posted by tison <wa...@gmail.com>.
'flink cancel' broken because of
https://issues.apache.org/jira/browse/FLINK-16626
Best,
tison.
Yun Tang <my...@live.com> 于2020年4月23日周四 上午1:18写道：
> 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 <se...@163.com>
> *Sent:* Wednesday, April 22, 2020 18:17
> *To:* user <us...@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.
>
>
>
Re: Flink 1.10.0 stop command
Posted by Yun Tang <my...@live.com>.
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 <se...@163.com>
Sent: Wednesday, April 22, 2020 18:17
To: user <us...@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.