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

Reply via email to