Now, I am able to create an class of flink she'll front end UI class. Once I have this instance, I can launch cmd in Java. Cmd has features to connect remote resource manager to do most if actions.
Thanks, Will > On Oct 3, 2016, at 4:31 AM, "LINZ, Arnaud" <al...@bouyguestelecom.fr> wrote: > > Hi, > > I have a similar issue. Here is how I deal with programmatically stopping > permanent streaming jobs, and I’m interested in knowing if there is a better > way now. > > Currently, I use hand-made streaming sources that periodically check for some > flag and end if a stop request was made. Stopping the source allow the > on-going streaming jobs to finish smoothly. > That way, by using a “live file” presence check in my sources, and creating a > “stopped ok file” when the streaming execution ends ok, I’m able to make “a > stopping shell script” that notify the streaming chain of a user cancellation > by deleting the “live file” and checking for the “stopped ok file” in a > waiting loop before ending. > > This stopping shell script allow me to automate “stop/start” scripts when I > need to perform some task (like a reference table refresh) that requires the > streaming job to be stopped (without cancelling it from the rest interface, > so without relying on the snapshot system to prevent the loss of intermediate > data, and allowing me to implement clean-up code if needed). > > The drawback of this method is not being able to use “off-the-shelf” sources > directly, I always have to wrap or patch them to implement the live file > check. > > Best regards, > Arnaud > > > De : Aljoscha Krettek [mailto:aljos...@apache.org] > Envoyé : mercredi 21 septembre 2016 14:54 > À : user@flink.apache.org; Max Michels <m...@apache.org> > Objet : Re: How to stop job through java API > > Hi, > right now this is not possible, I'm afraid. > > I'm looping in Max who has done some work in that direction. Maybe he's got > something to say. > > Cheers, > Aljoscha > > On Wed, 14 Sep 2016 at 03:54 Will Du <will...@gmail.com> wrote: > Hi folks, > How to stop link job given job_id through java API? > Thanks, > Will > > > 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.
