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
>
