Details
-
Bug
-
Status: Resolved
-
Blocker
-
Resolution: Fixed
-
1.5.0
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
- blocks
-
FLINK-8703 Migrate tests from LocalFlinkMiniCluster to MiniClusterResource
- Closed
- is blocked by
-
FLINK-8942 Pass target ResourceID to HeartbeatListener#retrievePayload
- Resolved