This is an automated email from the ASF dual-hosted git repository.
mmerli pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new bb2d7fc Add double quotation marks for metrics with remote_cluster
(#4295)
bb2d7fc is described below
commit bb2d7fc69af0bd72e56f5db04e9931a4e2d4adaa
Author: tuteng <[email protected]>
AuthorDate: Sat May 18 01:00:47 2019 +0800
Add double quotation marks for metrics with remote_cluster (#4295)
---
.../main/java/org/apache/pulsar/broker/stats/prometheus/TopicStats.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/TopicStats.java
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/TopicStats.java
index e887cae..7f65a3d 100644
---
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/TopicStats.java
+++
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/TopicStats.java
@@ -196,7 +196,7 @@ class TopicStats {
String topic,
String name, String remoteCluster, double value) {
stream.write(name).write("{cluster=\"").write(cluster).write("\",namespace=\"").write(namespace);
-
stream.write("\",topic=\"").write(topic).write("remote_cluster=\"").write(remoteCluster).write("\"}
");
+
stream.write("\",topic=\"").write(topic).write("\",remote_cluster=\"").write(remoteCluster).write("\"}
");
stream.write(value).write('
').write(System.currentTimeMillis()).write('\n');
}
}