flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "LINZ, Arnaud" <AL...@bouyguestelecom.fr>
Subject RE: How to cancel a Flink DataSource from the driver code?
Date Thu, 02 Jul 2015 07:35:06 GMT
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 !


De : ewenstephan@gmail.com [mailto:ewenstephan@gmail.com] De la part de Stephan Ewen
Envoyé : mercredi 1 juillet 2015 15:58
À : user@flink.apache.org
Objet : Re: How to cancel a Flink DataSource from the driver code?

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<mailto:ALINZ@bouyguestelecom.fr>>

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,


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