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

Accumulators not updated for running jobs

    XMLWordPrintableJSON

Details

    Description

      The FLIP-6 TaskExecutor is never sending the current state of accumulators to the JobMaster. They are only updated if the job is finished.

      The legacy TaskManager did this regularly as part of the heartbeat to the JobManager.

      This is a regression and blocks the porting of some tests (like the SavepointMigrationTestBase) that makes use of accumulators to determine when the job shutdown condition is fulfilled.

      Attachments

        Issue Links

          Activity

            People

              chesnay Chesnay Schepler
              chesnay Chesnay Schepler
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: