Hi XiangWei,
it is actually not intended to get access to the ExecutionGraph, because it
is a runtime component which does not make much sense to exist outside of
the JobManager. The RequestJob message is only a hack to make the
ExecutionGraph accessible to another actor running in the same ActorS
hi Till,
Sorry,I've made a mistake,i used
*StandaloneClusterClient*#*getJobManagerGateway
*to get *ActorGateway *to communicate with *JobManager *instead of using
*JobMasterGateway*.
Below is the code i executed for getting ExecuteGraph of a Job.
val flinkConfig = new Configuration()
Hi XiangWei,
how do you use the JobMasterGateway with the actor message RequestJob? The
JobMasterGateway is a Java interface and does not represent an ActorCell to
which you can send actor messages. Instead you should call
JobMasterGateway#requestArchivedExecutionGraph.
Cheers,
Till
On Tue, No
Hi XiangWei,
I don't think this is a public interface, but Till (in CC) might know
better.
Best,
Fabian
2017-11-06 3:27 GMT+01:00 XiangWei Huang :
> Hi Flink users,
> Flink Jobmanager throw a NotSerializableException when i used
> JobMasterGateway to get ExecutionGraph of a specific job with
>
Hi Flink users,
Flink Jobmanager throw a NotSerializableException when i used
JobMasterGateway to get ExecutionGraph of a specific job with
message RequestJob(jobID). Blow is the detail of Exception:
[ERROR] [akka.remote.EndpointWriter] - Transient association error (association
remain
