Flink 1.10 StopWithSavepoint only suit for the sources that implement the StoppableFunction interface?

classic Classic list List threaded Threaded
3 messages Options
Reply | Threaded
Open this post in threaded view
|

Flink 1.10 StopWithSavepoint only suit for the sources that implement the StoppableFunction interface?

LakeShen
Hi community,
        now  I am seeing the FLIP-45 , as I see the stop command only suit for the sources that implement the StoppableFunction interface. 
        So I have a question is that if I use StopWithSavepoint command to stop my flink task , just like './flink stop -p xxx ...', this command only suit for the sources that implement the StoppableFunction interface, is it correct?
        Thanks to your reply.

Best wishes,
LakeShen
Reply | Threaded
Open this post in threaded view
|

Re: Flink 1.10 StopWithSavepoint only suit for the sources that implement the StoppableFunction interface?

tison
The StoppableFunction is gone.


Best,
tison.


LakeShen <[hidden email]> 于2020年3月12日周四 下午5:44写道:
Hi community,
        now  I am seeing the FLIP-45 , as I see the stop command only suit for the sources that implement the StoppableFunction interface. 
        So I have a question is that if I use StopWithSavepoint command to stop my flink task , just like './flink stop -p xxx ...', this command only suit for the sources that implement the StoppableFunction interface, is it correct?
        Thanks to your reply.

Best wishes,
LakeShen
Reply | Threaded
Open this post in threaded view
|

Re: Flink 1.10 StopWithSavepoint only suit for the sources that implement the StoppableFunction interface?

LakeShen
Thanks a lot!, tison

tison <[hidden email]> 于2020年3月12日周四 下午5:56写道:
The StoppableFunction is gone.


Best,
tison.


LakeShen <[hidden email]> 于2020年3月12日周四 下午5:44写道:
Hi community,
        now  I am seeing the FLIP-45 , as I see the stop command only suit for the sources that implement the StoppableFunction interface. 
        So I have a question is that if I use StopWithSavepoint command to stop my flink task , just like './flink stop -p xxx ...', this command only suit for the sources that implement the StoppableFunction interface, is it correct?
        Thanks to your reply.

Best wishes,
LakeShen