Yes, it seems as if FlinkKinesisConsumer does not implement it. Here are the links to the respective javadoc [1] and code [2]. Note that in later releases (1.9+) this interface has been removed. Stop is now implemented through a cancel() on source level.
In general, I don't think that in a Kinesis to Kinesis use case, stop is needed anyways, since there is no additional consistency expected over a normal cancel. [1] https://ci.apache.org/projects/flink/flink-docs-release-1.6/api/java/org/apache/flink/api/common/functions/StoppableFunction.html [2] https://github.com/apache/flink/blob/release-1.6/flink-core/src/main/java/org/apache/flink/api/common/functions/StoppableFunction.java On Sat, Jun 6, 2020 at 8:03 PM M Singh <mans2si...@yahoo.com> wrote: > Hi Arvid: > > I check the link and it indicates that only Storm SpoutSource, > TwitterSource and NifiSource support stop. > > Does this mean that FlinkKinesisConsumer is not stoppable ? > > Also, can you please point me to the Stoppable interface mentioned in the > link ? I found the following but am not sure if TwitterSource implements > it : > > https://github.com/apache/flink/blob/8674b69964eae50cad024f2c5caf92a71bf21a09/flink-runtime/src/main/java/org/apache/flink/runtime/rpc/StartStoppable.java > > Thanks > > > > > > On Friday, June 5, 2020, 02:48:49 PM EDT, Arvid Heise <ar...@ververica.com> > wrote: > > > Hi, > > could you check if this SO thread [1] helps you already? > > [1] > https://stackoverflow.com/questions/53735318/flink-how-to-solve-error-this-job-is-not-stoppable > > On Thu, Jun 4, 2020 at 7:43 PM M Singh <mans2si...@yahoo.com> wrote: > > Hi: > > I am running a job which consumes data from Kinesis and send data to > another Kinesis queue. I am using an older version of Flink (1.6), and > when I try to stop the job I get an exception > > Caused by: java.util.concurrent.ExecutionException: > org.apache.flink.runtime.rest.util.RestClientException: [Job termination > (STOP) failed: This job is not stoppable.] > > > I wanted to find out what is a stoppable job and it possible to make a job > stoppable if is reading/writing to kinesis ? > > Thanks > > > > > -- > > Arvid Heise | Senior Java Developer > > <https://www.ververica.com/> > > Follow us @VervericaData > > -- > > Join Flink Forward <https://flink-forward.org/> - The Apache Flink > Conference > > Stream Processing | Event Driven | Real Time > > -- > > Ververica GmbH | Invalidenstrasse 115, 10115 Berlin, Germany > > -- > Ververica GmbH > Registered at Amtsgericht Charlottenburg: HRB 158244 B > Managing Directors: Timothy Alexander Steinert, Yip Park Tung Jason, Ji > (Toni) Cheng > -- Arvid Heise | Senior Java Developer <https://www.ververica.com/> Follow us @VervericaData -- Join Flink Forward <https://flink-forward.org/> - The Apache Flink Conference Stream Processing | Event Driven | Real Time -- Ververica GmbH | Invalidenstrasse 115, 10115 Berlin, Germany -- Ververica GmbH Registered at Amtsgericht Charlottenburg: HRB 158244 B Managing Directors: Timothy Alexander Steinert, Yip Park Tung Jason, Ji (Toni) Cheng
