flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Stephan Ewen <se...@apache.org>
Subject Re: How to cancel a Flink DataSource from the driver code?
Date Wed, 01 Jul 2015 13:57:58 GMT
Hi Arnaud!

There is a pending issue and pull request that is adding a "cancel()" call
to the command line interface.


It would be possible to extend that such that the driver can also cancel
the program.


On Wed, Jul 1, 2015 at 3:33 PM, LINZ, Arnaud <ALINZ@bouyguestelecom.fr>

>  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.

View raw message