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

Make the ExecutionGraph independent of Akka

    XMLWordPrintableJSON

Details

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

    Description

      Currently, the ExecutionGraph strongly depends on Akka as it requires an ActorSystem to create the CheckpointCoordinatorDeActivator. Furthermore, it allows ActorGateways to register for job status and execution updates.

      In order to improve modularization and abstraction I propose to introduce proper listener interfaces. This would also allow to get rid of the CheckpointCoordinatorDeActivator by simply implementing this interface. Furthermore it will pave the way for the upcoming Flip-6 refactoring as it offers a better abstraction.

      Attachments

        Issue Links

          duplicates

          Sub-task - The sub-task of the issue FLINK-4448 Use Listeners to monitor execution status

          • 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-4344 Implement new JobManager

          • Major - Major loss of function.
          • Resolved

          Activity

            People

              sewen Stephan Ewen
              trohrmann Till Rohrmann
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: