Thanks for the suggestion.
After digging a bit, we've found it most convenient to just add labels to
all our Prometheus queries, like this:
flink_taskmanager_job_task_operator_currentOutputWatermark{job_name=""}
The job_name label will be exposed if you run your job with a job name like
this:
s
Hi Ori,
Another more temporary brute-force option, while not officially flink, could be
building a modified version of the metrics plugin into flink where you manually
manipulate the prefixes yourself. It’s actually pretty easy to build the jar,
and to test it you drop the jar into the plugin p
