Chesnay Schepler created FLINK-8881:

             Summary: Accumulators not updated for running jobs
                 Key: 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 

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

Reply via email to