This is called "stop" in Flink. You can find a short description here:
https://ci.apache.org/projects/flink/flink-docs-release-1.2/setup/cli.html
" The difference between cancelling and stopping a (streaming) job is
the following:
On a cancel call, the operators in a job immediately receive a cancel()
method call to cancel them as soon as possible. If operators are not not
stopping after the cancel call, Flink will start interrupting the thread
periodically until it stops.
A “stop” call is a more graceful way of stopping a running streaming
job. Stop is only available for jobs which use sources that implement
the StoppableFunction interface. When the user requests to stop a job,
all sources will receive a stop() method call. The job will keep running
until all sources properly shut down. This allows the job to finish
processing all inflight data."
Hope that helps.
Timo
Am 10/05/17 um 13:26 schrieb yunfan123:
How can I deactive a job like storm?
--
View this message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Deactive-a-job-like-storm-tp13088.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at
Nabble.com.
