[FLINK-4653] Refactor JobClientActor to adapt to the new Rpc framework and new cluster managerment

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Invalid
• Component/s: Command Line Client
• Assignee: Jing Zhang
• Reporter: Jing Zhang
• Created: 21/Sep/16 09:32
• Updated: 27/Jan/22 17:43
• Resolved: 24/Apr/19 04:20

Description

1. Create a RpcEndpoint(temporary named JobInfoTracker) and RpcGateway(temporary named JobInfoTrackerGateway) to replace the old JobClientActor.
2. Change rpc message communication in JobClientActor to rpc method call to apply to the new rpc framework.
3. JobInfoTracker is responsible for waiting for the jobStateChange and jobResult util job complete. But it is not responsible for submitting new job because jobSubmission behavior is different in different cluster

Issue Links

• links to: GitHub Pull Request #2524