[GitHub] flink issue #2358: [FLINK-4382] Buffer rpc calls until the RpcEndpoint has b...

2016-08-15 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2358 The stashing is a feature which comes for free with Akka. Of course the sending side should not rely on this behaviour when implementing its failure treatment. But in cases where we have a race

[GitHub] flink issue #2358: [FLINK-4382] Buffer rpc calls until the RpcEndpoint has b...

2016-08-12 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2358 Dropping is also a solution. I think this will also happen implicitly if the mailbox grows too big. Stashing has the advantage that we try (on a best effort basis) to answer early

[GitHub] flink issue #2358: [FLINK-4382] Buffer rpc calls until the RpcEndpoint has b...

2016-08-11 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2358 Not completely sure about the message stashing. Why not drop the messages? That would be safer (less to clean up, no overflow). Is this mainly to not loose the messages from the "self