Hi!
You can also cancel jobs via the command line. See here:
https://ci.apache.org/projects/flink/flink-docs-release-0.9/apis/cli.html
There is also a way to do that programmatically, from Java or Scala.
Greetings,
Stephan
On Wed, Jul 15, 2015 at 4:58 PM, LINZ, Arnaud al...@bouyguestelecom.fr
Hi Stephan,
I think that clean shutdown is a major feature to build a complex persistent
service that use Flink Streaming for a data-quality critical task, and I’ll
mark my code with a // FIXME comment waiting for this feature to be available !
Greetings,
Arnaud
De : ewenstep...@gmail.com
Hello,
I really looked in the documentation but unfortunately I could not find the
answer: how do you cancel your data SourceFunction from your “driver” code
(i.e., from a monitoring thread that can initiate a proper shutdown) ? Calling
“cancel()” on the object passed to the addSource() has no