Hi All
Based on my code reading, I have following understanding of the Metrics
and Accumulators.
1. Accumulators for a Flink JOB work like global counters. They are
designed so that accumulator values from different instances of Execution
Vertex can be combined. They are essentially distribut
t; Cheers,
> Aljoscha
>
> On Wed, 21 Sep 2016 at 21:15 Chawla,Sumit wrote:
>
> > Hi Sean
> >
> > My goal here is to get User Accumulators. I know there exists the REST
> > Calls. But since i am running my code in the same JVM, i wanted to avoid
> > go over HT
s not easily possible, and not intended, as it
> actually contains RPC resources, etc.
>
> What do you need from the execution graph? Maybe there is another way to
> achieve that...
>
> On Wed, Sep 21, 2016 at 8:08 PM, Chawla,Sumit
> wrote:
>
> > Hi Chesney
> >
> &
issue you stumbled upon here.
>
> The ExecutionGraph is not serializable. The only reason why the
> WebInterface can access it is because it runs in the same JVM as the
> JobManager.
>
> I'm not sure if there is a way for what you are trying to do.
>
> Regards,
> Chesna
Hi All
I am trying to get JOB accumulators. ( I am aware that I can get the
accumulators through REST APIs as well, but i wanted to avoid JSON
parsing).
Looking at JobAccumulatorsHandler i am trying to get execution graph for
currently running job. Following is my code:
InetSocketAddress i
Has anyone else run these kind of benchmarks? Would love to hear more
people'e experience and details about those benchmarks.
Regards
Sumit Chawla
On Sun, Sep 18, 2016 at 2:01 PM, Chawla,Sumit
wrote:
> Hi Amir
>
> Would it be possible for you to share the numbers? Also sha
12/2015:
> https://yahooeng.tumblr.com/post/135321837876/benchmarking-streaming-
> computation-engines-at
> [3] 02/2016:
> http://data-artisans.com/extending-the-yahoo-streaming-benchmark/
>
>
> 2016-09-16 5:54 GMT+02:00 Chawla,Sumit :
>
> > Hi
> >
> &g
Hi
Is there any performance run that is done for each Flink release? Or you
are aware of any third party evaluation of performance metrics for Flink?
I am interested in seeing how performance has improved over release to
release, and performance vs other competitors.
Regards
Sumit Chawla
