possible
Will NiFi be a possible alternative? Are there any other option?
*From:* Aljoscha Krettek
*Subject:* How can I cancel a Flink job safely without a special stop
message in the stream?
*Date:* Friday, Aug 25, 2017 19:45
Hi,
I don't think implementing a StoppableSource is an option here since you want
to use the Flink Kafka source. What is your motivation for this? Especially,
why are you using Kafka if the input is bounded and you will shut down the job
at some point?
Also, regarding StoppableSource: this wil
Hi,
have you tried letting your source also implement the StoppableFunction
interface as suggested by the SourceFunction javadoc?
If a source is stopped, e.g. after identifying some special signal from the
outside, it will continue processing all remaining events and the Flink
program will shu
Bump...
在 2017/8/11 9:36, Zor X.L. 写道:
Hi,
What we want to do is cancelling the Flink job after all upstream data
were processed.
We use Kafka as our input and output, and use the SQL capability of
Table API by the way.
A possible solution is:
*
embed a stop message at the tail of
Hi,
What we want to do is cancelling the Flink job after all upstream data
were processed.
We use Kafka as our input and output, and use the SQL capability of
Table API by the way.
A possible solution is:
*
embed a stop message at the tail of upstream
*
do what should be done in t
