Hi Yan Chou Chen,
1.
At the moment Flink sources have to implement a certain interface,
StoppableFunction, to be stoppable. If they do, then you can stop them
via the CLI or the web interface. This cannot be triggered from within a
job.
However, you have a far better way to pro
Several new questions:
- Stoppable job
I read threads mentioning that a streaming job can be stopped [1][2].
However looks like it can only be called through command line. Is it
possible to programmatically stop the streaming job from within the
job itself? For instance, a Kafka consumer streaming
