[
https://issues.apache.org/jira/browse/FLINK-19468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-19468.
------------------------------------
Resolution: Later
We may rectify this issue at some point (2.0?), but for now we leave things as
is to not break setups.
When requesting metrics containing special characters the user is required to
escape them.
> Metrics return empty when data stream / operator name contains "+"
> ------------------------------------------------------------------
>
> Key: FLINK-19468
> URL: https://issues.apache.org/jira/browse/FLINK-19468
> Project: Flink
> Issue Type: Bug
> Components: API / DataStream, Runtime / Metrics
> Affects Versions: 1.9.0, 1.9.2, 1.9.3
> Reporter: Boyang Jerry Peng
> Assignee: Boyang Jerry Peng
> Priority: Major
> Labels: pull-request-available
> Attachments: StreamingJob.java
>
>
> 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
> ```
> $ curl
> [http://localhost:8081/jobs/5d4f28a221b2e5762f8404398a462eb0/vertices/cbc357ccb763df2852fee8c4fc7d55f2/metrics?get=0.Source__testing_+_plus.numRecordsOut]
> []
> ```
>
> The http request is also made from the UI if you view the metric
> "[0.Source__testing_+_plus.numRecordsOut|http://localhost:8081/jobs/5d4f28a221b2e5762f8404398a462eb0/vertices/cbc357ccb763df2852fee8c4fc7d55f2/metrics?get=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:
> [https://github.com/apache/flink/blob/master/flink-runtime/src/main/java/org/apache/flink/runtime/metrics/dump/MetricQueryService.java#L208]
> It does not consider "+" character?
>
> I have attached the full example to reproduce the issue.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
