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.

See also https://issues.apache.org/jira/browse/FLINK-11889

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.
>
> See also https://issues.apache.org/jira/browse/FLINK-11889
>
> 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
>>
>