...
in order to retrieve a “live” ExecutionGraph
, proposed implementation can instead utilize an ArchivedExecutionGraph
. It is already available in the web monitor endpoint and can be directly used for localizing operator’s Tasks
and their corresponding TaskExecutors
. ThreadInfoRequestCoordinator
can therefore be initialized and executed as part of the WebMonitorEndpoint
instead of “polluting” adding non-core functionality to the JobManagerSharedServices
with non-core functionality.
Call flow is illustrated by the following sequence diagram (click to zoom):
...