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.

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

Mime
View raw message