[jira] [Created] (FLINK-8881) Accumulators not updated for running jobs

[Shang Yuanchun (Jira)]

Chesnay Schepler created FLINK-8881:
---------------------------------------

             Summary: Accumulators not updated for running jobs
                 Key: FLINK-8881
                 URL: https://issues.apache.org/jira/browse/FLINK-8881
             Project: Flink
          Issue Type: Bug
          Components: DataSet API, DataStream API, Distributed Coordination, JobManager, TaskManager
    Affects Versions: 1.5.0
            Reporter: Chesnay Schepler
             Fix For: 1.5.0


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.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)