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');
     }
 }

Reply via email to