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

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

                Dates

                • Created:
                  Updated:
                  Resolved: