You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by si...@apache.org on 2019/06/04 18:47:03 UTC
[pulsar] branch master updated: Fix log format for module
pulsar-client (#4436)
This is an automated email from the ASF dual-hosted git repository.
sijie 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 39551bb Fix log format for module pulsar-client (#4436)
39551bb is described below
commit 39551bb7518bd7196d9f94adf2b5ebf20c139bf0
Author: Like <ke...@outlook.com>
AuthorDate: Wed Jun 5 02:46:57 2019 +0800
Fix log format for module pulsar-client (#4436)
Fix log format for module pulsar-client.
Part of #4304
---
.../java/org/apache/pulsar/client/impl/PartitionedProducerImpl.java | 2 +-
.../java/org/apache/pulsar/client/impl/ProducerStatsRecorderImpl.java | 2 +-
.../java/org/apache/pulsar/client/impl/PulsarServiceNameResolver.java | 2 +-
3 files changed, 3 insertions(+), 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
index bfc6645..40f2240 100644
--- 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 class PartitionedProducerImpl<T> extends ProducerBase<T> {
}
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
index 86bed80..25cb724 100644
--- 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 @@ public class ProducerStatsRecorderImpl implements ProducerStatsRecorder {
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
index 9d15ccf..443cfc5 100644
--- 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 class PulsarServiceNameResolver implements ServiceNameResolver {
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);
}
}