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 
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

Reply via email to