Thanks Till
It worked after updating the property in flink-conf.yaml file.
Thanks,
Kasif
From: Till Rohrmann [mailto:trohrm...@apache.org]
Sent: Wednesday, March 15, 2017 9:08 PM
To: user@flink.apache.org
Subject: Re: flink akka OversizedPayloadException error
Hi Kasif,
using the
Hi Kasif,
using the akka.framesize configuration option is the right way to solve the
problem with large akka messages. I’ve tested what you’ve described with
the latest 1.2 release branch and it worked for me.
In order to track down your problem I need some more information. First of
all you can
Hello,
We have added a serializer code which register all the schemas with
executionEnvironment and is called before execute(). This is to make sure that
all the avro schemas are pre-registered and cached in executors before actual
execution begin. Now while submitting the job we are getting
