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 continue its execution forever, with an infinite number of such messages: Checkpoint triggering task Source: Custom Source (1/2) of job 3b286f5344c50f0e466bb8ee79a2bb69 is not in state RUNNING but SCHEDULED instead. Aborting checkpoint. Why has this behavior changed? How am I supposed to stop a streaming execution from its own code now? Is https://issues.apache.org/jira/browse/FLINK-2111 of any use? Thanks, 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.
