Have you tried the object reuse option mentioned above?

On Tue, Jan 24, 2017 at 6:52 PM, Jonas <jo...@huntun.de> wrote:

> The performance hit due to decoding the JSON is expected and there is not a
> lot (except for changing the encoding that I can do about that). Alright.
>
> When joining the above stream with another stream I get another performance
> hit by ~80% so that in the end I have only 1k msgs/s remaining. Do you know
> how to improve that? Might setting the buffer size / timeout be worth
> exploring?
>
>
>
>
> --
> View this message in context: http://apache-flink-user-
> mailing-list-archive.2336050.n4.nabble.com/Improving-Flink-
> Performance-tp11248p11272.html
> Sent from the Apache Flink User Mailing List archive. mailing list archive
> at Nabble.com.
>

Reply via email to