Client communication and akka.framesize

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

Client communication and akka.framesize

Felix Schüler
Hi,

we were running into the same problem that was described here[0] and are
wondering if anyone is still working on/interested in this PR[1].
It would be great if this could be merged since we are collecting and
distributing data of unknown sizes at the time of configuration and this
leads to unexpected failures.

Thanks!
Felix

[0] https://issues.apache.org/jira/browse/FLINK-2603
[1] https://github.com/apache/flink/pull/934
mxm
Reply | Threaded
Open this post in threaded view
|

Re: Client communication and akka.framesize

mxm
Hi Felix,

I don't think this PR will go in any time soon. Transferring data back
to the client is not a very efficient anyways. Perhaps you could
re-formulate your problem in a different way?

Adjusting the framesize could also be an option:
https://ci.apache.org/projects/flink/flink-docs-master/setup/config.html#distributed-coordination-via-akka

Cheers,
Max

On Wed, Jun 1, 2016 at 3:51 PM,  <[hidden email]> wrote:

> Hi,
>
> we were running into the same problem that was described here[0] and are
> wondering if anyone is still working on/interested in this PR[1].
> It would be great if this could be merged since we are collecting and
> distributing data of unknown sizes at the time of configuration and this
> leads to unexpected failures.
>
> Thanks!
> Felix
>
> [0] https://issues.apache.org/jira/browse/FLINK-2603
> [1] https://github.com/apache/flink/pull/934