Hi Max, actually I have a jar containing sampling jobs and I need to collect results from a client. I've tried to use ExecutionEnvironment.createRemoteEnvironment but I fear that it's not the right way to do that because I just need to tell the cluster the main class and the parameters to run the job (and where the jar file is on HDFS).
Best, Flavio On Tue, Sep 27, 2016 at 12:06 PM, Maximilian Michels <m...@apache.org> wrote: > Hi Flavio, > > Do you want to sample from a running batch job? That would be like > Queryable State in streaming jobs but it is not supported in batch > mode. > > Cheers, > Max > > > On Mon, Sep 26, 2016 at 6:13 PM, Flavio Pompermaier > <pomperma...@okkam.it> wrote: > > Hi to all, > > > > I have a use case where I need to tell a Flink cluster to give me a > sample > > of X records using parametrizable sampling functions. Is there any best > > practice or advice to do that? > > > > Should I create a Remote ExecutionEnvironment or should I use the Flink > > client (I don't know if it uses REST services or RPC or whatever)? > > Is there any java snippet for that? > > > > Best, > > Flavio > > >
