Fix log format for module pulsar-client (apache#4436)

Fix log format for module pulsar-client. Part of apache#4304
lionelcao · Jun 4, 2019 · 39551bb · 39551bb
1 parent fc59074
commit 39551bb
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/PartitionedProducerImpl.java b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/PartitionedProducerImpl.java
@@ -343,7 +343,7 @@ public void run(Timeout timeout) throws Exception {
             }
 
             if (log.isDebugEnabled()) {
-                log.debug("[{}]  run partitionsAutoUpdateTimerTask for partitioned producer: {}", topic);
+                log.debug("[{}] run partitionsAutoUpdateTimerTask for partitioned producer", topic);
             }
 
             // if last auto update not completed yet, do nothing.

diff --git a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerStatsRecorderImpl.java b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerStatsRecorderImpl.java
@@ -101,7 +101,7 @@ private void init(ProducerConfigurationData conf) {
             log.info("Starting Pulsar producer perf with config: {}", w.writeValueAsString(conf));
             log.info("Pulsar client config: {}", w.withoutAttribute("authentication").writeValueAsString(pulsarClient.getConfiguration()));
         } catch (IOException e) {
-            log.error("Failed to dump config info: {}", e);
+            log.error("Failed to dump config info", e);
         }
 
         stat = (timeout) -> {

diff --git a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/PulsarServiceNameResolver.java b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/PulsarServiceNameResolver.java
@@ -92,7 +92,7 @@ public void updateServiceUrl(String serviceUrl) throws InvalidServiceURL {
                 URI hostUri = new URI(hostUrl);
                 addresses.add(InetSocketAddress.createUnresolved(hostUri.getHost(), hostUri.getPort()));
             } catch (URISyntaxException e) {
-                log.error("Invalid host provided {}", hostUrl, e.getMessage(), e);
+                log.error("Invalid host provided {}", hostUrl, e);
                 throw new InvalidServiceURL(e);
             }
         }