Hi Arnaud! There is a pending issue and pull request that is adding a "cancel()" call to the command line interface.
https://github.com/apache/flink/pull/750 It would be possible to extend that such that the driver can also cancel the program. Greetings, Stephan On Wed, Jul 1, 2015 at 3:33 PM, LINZ, Arnaud <al...@bouyguestelecom.fr> wrote: > 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 effect > since it does not apply to the marshalled distributed object(s). > > > > Best regards, > > Arnaud > > > > > > ------------------------------ > > L'intégrité de ce message n'étant pas assurée sur internet, la société > expéditrice ne peut être tenue responsable de son contenu ni de ses pièces > jointes. Toute utilisation ou diffusion non autorisée est interdite. Si > vous n'êtes pas destinataire de ce message, merci de le détruire et > d'avertir l'expéditeur. > > The integrity of this message cannot be guaranteed on the Internet. The > company that sent this message cannot therefore be held liable for its > content nor attachments. Any unauthorized use or dissemination is > prohibited. If you are not the intended recipient of this message, then > please delete it and notify the sender. >
