On 20.11.20 22:09, Flavio Pompermaier wrote:
To achieve this, I was using the
RestClusterClient<StandaloneClusterId> because with that I can use the
following code and retrieve the JobID:
(1) JobID flinkJobId =
client.submitJob(jobGraph).thenApply(DetachedJobExecutionResult::new).get().getJobID();
All you want to do is get the JobID, correct? If yes, you can just do a
`jobGraph.getJobID()`. The job id is not set on the cluster but it's
actually set client side, on the JobGraph object.
Does that help in your case?
A general comment on your other questions: yes, the listener logic if
only used when using the environments. It's not integrated with the
RestClusterClient, which is considered more of an internal
implementation detail.
Aljoscha