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)
