It seems that the JobListener interface could not expose such
information. Maybe you can set the RuleId as the jobName(or the suffix
of the jobName) of the application, then you can get the mappings of
jobId to jobName(RuleId) throw /jobs/overview.
[1]
https://ci.apache.org/projects/flink/flink-d
Hi all,
I am building an application that launches Flink Jobs and monitors them.
I want to use the JobListener interface to output job evemts to a Kafka Topic.
The problem:
In the application we have RuleId, i.e. business logic identifier for the job,
and there’s JobId which is the internal
