in a jira description
> was an awful experience J)
>
>
>
>
>
> *De :* LINZ, Arnaud
> *Envoyé :* mercredi 7 novembre 2018 11:43
> *À :* 'user'
> *Objet :* RE: Stopping a streaming app from its own code : behaviour
> change from 1.3 to 1.6
>
>
>
> F
rService:135)
[2018-11-07 11:11:23,608] INFO Stopped TaskExecutor
akka://flink/user/taskmanager_0.
(org.apache.flink.runtime.taskexecutor.TaskExecutor:330)
De : LINZ, Arnaud
Envoyé : mardi 6 novembre 2018 14:23
À : user mailto:user@flink.apache.org>>
Objet : Stopping a streaming app from
FYI, the code below ends with version 1.6.0, do not end in 1.6.1. I suspect
it’s a bug instead of a new feature.
De : LINZ, Arnaud
Envoyé : mercredi 7 novembre 2018 11:14
À : 'user'
Objet : RE: Stopping a streaming app from its own code : behaviour change from
1.3 to 1.6
Hello,
_0.
(org.apache.flink.runtime.taskexecutor.TaskExecutor:330)
De : LINZ, Arnaud
Envoyé : mardi 6 novembre 2018 14:23
À : user
Objet : Stopping a streaming app from its own code : behaviour change from 1.3
to 1.6
Hello,
In flink 1.3, I was able to make a clean stop of a HA streaming application
jus
Hello,
In flink 1.3, I was able to make a clean stop of a HA streaming application
just by ending the source “run()” method (with an ending condition).
I try to update my code to flink 1.6.2, but that is no longer working.
Even if there are no sources and no item to process, the cluster con
