lto:rmetz...@apache.org]
> *Envoyé :* jeudi 2 juillet 2015 09:48
> *À :* user@flink.apache.org
> *Objet :* Re: How to cancel a Flink DataSource from the driver code?
>
>
>
> Hi Arnaud,
>
>
>
> when using the PersistentKafkaSource, you can always cancel the job in the
&
enstep...@gmail.com<mailto:ewenstep...@gmail.com>
[mailto:ewenstep...@gmail.com<mailto:ewenstep...@gmail.com>] De la part de
Stephan Ewen
Envoyé : mercredi 1 juillet 2015 15:58
À : user@flink.apache.org<mailto:user@flink.apache.org>
Objet : Re: How to cancel a Flink DataSource from t
>
>
>
>
>
> *De :* ewenstep...@gmail.com [mailto:ewenstep...@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
[mailto:ewenstep...@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 co
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
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
