[FLINK-10718] Use IO executor in RpcService for message serialization

• Type: Improvement
• Status: Open
• Priority: Not a Priority
• Resolution: Unresolved
• Affects Version/s: 1.5.5, 1.6.2, 1.7.0
• Component/s: Runtime / Task
• Labels: auto-deprioritized-major auto-deprioritized-minor pull-request-available
• Assignee: Unassigned
• Reporter: Till Rohrmann
• Created: 29/Oct/18 14:38
• Updated: 01/Dec/21 22:38

Description

The AkkaInvocationHandler and once FLINK-10251 has been merged also the AkkaRpcActor serialize their remote RPC messages before sending them. This happens in the calling thread which can be a main thread of another RpcEndpoint. Depending on the de-/serialization time, this can be considered a blocking operation. Thus, I propose to introduce an IO executor which is being used for the serialization of the messages. This will make the RpcService abstraction more scalable.

Issue Links

• is related to: FLINK-4346 Implement basic RPC abstraction
• links to: GitHub Pull Request #7718