I was under the impression that the @AfterClass annotation can only be used in test classes. Even so, the idea is that a user program running in the IDE should not be starting up the cluster several times [my primary concern is the addition of the persist operator], and we certainly cannot ask the user to terminate the cluster after execution, while in local mode.
-- Sachin Goel Computer Science, IIT Delhi m. +91-9871457685 On Wed, Sep 2, 2015 at 9:19 PM, Till Rohrmann <trohrm...@apache.org> wrote: > Why is it not possible to shut down the local cluster? Can’t you shut it > down in the @AfterClass method? > > > On Wed, Sep 2, 2015 at 4:56 PM, Sachin Goel <sachingoel0...@gmail.com> > wrote: > >> Yes. That will work too. However, then it isn't possible to shut down the >> local cluster. [Is it necessary to do so or does it shut down automatically >> when the program exists? I'm not entirely sure.] >> >> -- Sachin Goel >> Computer Science, IIT Delhi >> m. +91-9871457685 >> >> On Wed, Sep 2, 2015 at 7:59 PM, Stephan Ewen <se...@apache.org> wrote: >> >>> Have a look at some other tests, like the checkpointing tests. They >>> start one cluster manually and keep it running. They connect against it >>> using the remote environment ("localhost", >>> miniCluster.getJobManagerRpcPort()). >>> >>> That works nicely... >>> >>> On Wed, Sep 2, 2015 at 4:23 PM, Sachin Goel <sachingoel0...@gmail.com> >>> wrote: >>> >>>> Hi all >>>> While using LocalEnvironment, in case the program triggers execution >>>> several times, the {{LocalFlinkMiniCluster}} is started as many times. This >>>> can consume a lot of time in setting up and tearing down the cluster. >>>> Further, this hinders with a new functionality I'm working on based on >>>> persisted results. >>>> One potential solution could be to follow the methodology in >>>> `MultipleProgramsTestBase`. The user code then would have to reside in a >>>> fixed function name, instead of the main method. Or is that too cumbersome? >>>> >>>> Regards >>>> Sachin >>>> -- Sachin Goel >>>> Computer Science, IIT Delhi >>>> m. +91-9871457685 >>>> >>> >>> >> >