If I submit a Flink job in which a stream has a name that contains a "+" character, the metrics returned for the stream is always empty. For example:
env.addSource(new TestSource()).name("testing + plus");
If I try to get the metrics
The http request is also made from the UI if you view the metric "0.Source_testing+_plus.numRecordsOut".
The metrics will always return empty. However if I remove the "+" from the name of the stream. Metrics are returned non-empty.
Maybe it has something to do with this method:
It does not consider "+" character?
I have attached the full example to reproduce the issue.