Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-4456

Replace ActorGateway in Task by interface

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Closed
    • Major
    • Resolution: Fixed
    • None
    • None
    • Runtime / Coordination
    • None

    Description

      The Task communicates with the outside world (JobManager and TaskManager) via ActorGateways. This bakes in the dependency on actors.
      In terms of modularization and an improved abstraction (especially wrt Flip-6) I propose to replace the ActorGateways by interfaces which exposes the required methods. The current implementation would then simply wrap the method calls in messages and send them via the ActorGateway to the recipient.

      In Flip-6 the JobMaster could simply implement these interfaces as part of their RPC contract.

      Attachments

        Issue Links

          blocks

          Sub-task - The sub-task of the issue FLINK-4358 Implement TaskManager deployment task into slot

          • Major - Major loss of function.
          • Closed
          is depended upon by

          New Feature - A new feature of the product, which has yet to be developed. FLINK-4343 Implement new TaskManager

          • Major - Major loss of function.
          • Resolved
          relates to

          Improvement - An improvement or enhancement to an existing feature or task. FLINK-4455 Replace ActorGateways in NetworkEnvironment by interfaces

          • Major - Major loss of function.
          • Closed
          links to

          Web Link GitHub Pull Request #2456

          Activity

            People

              trohrmann Till Rohrmann
              trohrmann Till Rohrmann
              Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: