yanghua commented on issue #6876: [FLINK-10251] Handle oversized response messages in AkkaRpcActor URL: https://github.com/apache/flink/pull/6876#issuecomment-431640196 hi @tillrohrmann There is a problem about sending serialized data. For example, `testNoSlotSharingAndBlockingResultReceiver` will trigger `allocateSlot` rpc call, the result type is `SingleLogicalSlot` which has a field `private final CompletableFuture<Void> releaseFuture`. The field caused serialization error : ``` Caused by: org.apache.flink.runtime.rpc.akka.exceptions.AkkaRpcException: Failed to serialize the result for RPC call : allocateSlot. at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.serializeResultAndVerifySize(AkkaRpcActor.java:335) at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRpcInvocation$1(AkkaRpcActor.java:280) ... 33 more Caused by: java.io.NotSerializableException: java.util.concurrent.CompletableFuture ```
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected] With regards, Apache Git Services
