Re: How to cancel a Flink DataSource from the driver code?

2015-07-15 Thread Stephan Ewen
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

RE: How to cancel a Flink DataSource from the driver code?

2015-07-02 Thread LINZ, Arnaud
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