You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@flink.apache.org by LakeShen <sh...@gmail.com> on 2020/03/12 09:44:00 UTC

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

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

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

Posted by LakeShen <sh...@gmail.com>.
Thanks a lot!, tison

tison <wa...@gmail.com> 于2020年3月12日周四 下午5:56写道:

> The StoppableFunction is gone.
>
> See also https://issues.apache.org/jira/browse/FLINK-11889
>
> Best,
> tison.
>
>
> LakeShen <sh...@gmail.com> 于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
>>
>

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

Posted by LakeShen <sh...@gmail.com>.
Thanks a lot!, tison

tison <wa...@gmail.com> 于2020年3月12日周四 下午5:56写道:

> The StoppableFunction is gone.
>
> See also https://issues.apache.org/jira/browse/FLINK-11889
>
> Best,
> tison.
>
>
> LakeShen <sh...@gmail.com> 于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
>>
>

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

Posted by LakeShen <sh...@gmail.com>.
Thanks a lot!, tison

tison <wa...@gmail.com> 于2020年3月12日周四 下午5:56写道:

> The StoppableFunction is gone.
>
> See also https://issues.apache.org/jira/browse/FLINK-11889
>
> Best,
> tison.
>
>
> LakeShen <sh...@gmail.com> 于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
>>
>

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

Posted by tison <wa...@gmail.com>.
The StoppableFunction is gone.

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

Best,
tison.


LakeShen <sh...@gmail.com> 于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
>

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

Posted by tison <wa...@gmail.com>.
The StoppableFunction is gone.

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

Best,
tison.


LakeShen <sh...@gmail.com> 于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
>

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

Posted by tison <wa...@gmail.com>.
The StoppableFunction is gone.

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

Best,
tison.


LakeShen <sh...@gmail.com> 于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
>