zhangjing created FLINK-4653:
--------------------------------
Summary: Refactor JobClientActor to adapt to the new Rpc framework
and new cluster managerment
Key: FLINK-4653
URL: https://issues.apache.org/jira/browse/FLINK-4653
Project: Flink
Issue Type: Sub-task
Components: Client
Reporter: zhangjing
Assignee: zhangjing
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
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
