Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2616
The `CoordinatorShutdownTest` can't be fixed with a cast. This test assumes
that the actual ExecutionGraph is still available when a job is finished since
it tries to access the CheckpointCoordinator within. This however no longer
works; finished jobs are immediately archived, and the archived version does
not contain the CheckpointCoordinator.
A possible fix is to not let the job fail immediately but block him, ask
for the ExecutionGraph while being blocked (which, since the job is still
running actually returns the runtime ExecutionGraph) and store the reference,
and then let the job fail.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
