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

Accumulators not updated for running jobs

    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:
                Zentol Chesnay Schepler
                Reporter:
                Zentol Chesnay Schepler
              • Votes:
                0 Vote for this issue
                Watchers:
                3 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: