[pulsar] branch master updated: Fix log placeholders not correct (#12014)

[mmerli]

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 524b103  Fix log placeholders not correct (#12014)
524b103 is described below

commit 524b1030fe16d26290d4c15cb16890c3ad3d7267
Author: Shoothzj <shoot...@gmail.com>
AuthorDate: Wed Sep 15 00:46:59 2021 +0800

    Fix log placeholders not correct (#12014)
---
 .../apache/pulsar/broker/service/nonpersistent/NonPersistentTopic.java  | 2 +-
 .../main/java/org/apache/pulsar/common/util/netty/EventLoopUtil.java    | 2 +-
 .../org/apache/pulsar/io/kafka/connect/PulsarOffsetBackingStore.java    | 2 +-
 .../org/apache/pulsar/metadata/coordination/impl/ResourceLockImpl.java  | 2 +-
 4 files changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentTopic.java
 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentTopic.java
index 90b4963..97258ec 100644
--- 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentTopic.java
+++ 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentTopic.java
@@ -146,7 +146,7 @@ public class NonPersistentTopic extends AbstractTopic 
implements Topic {
                 .getAsync(AdminResource.path(POLICIES, 
TopicName.get(topic).getNamespace()))
                 .thenAccept(optPolicies -> {
                     if (!optPolicies.isPresent()) {
-                        log.warn("[{}] Policies not present {} and 
isEncryptionRequired will be set to false", topic);
+                        log.warn("[{}] Policies not present and 
isEncryptionRequired will be set to false", topic);
                         isEncryptionRequired = false;
                     } else {
                         Policies policies = optPolicies.get();
diff --git 
a/pulsar-common/src/main/java/org/apache/pulsar/common/util/netty/EventLoopUtil.java
 
b/pulsar-common/src/main/java/org/apache/pulsar/common/util/netty/EventLoopUtil.java
index 0a3564b..713bc61 100644
--- 
a/pulsar-common/src/main/java/org/apache/pulsar/common/util/netty/EventLoopUtil.java
+++ 
b/pulsar-common/src/main/java/org/apache/pulsar/common/util/netty/EventLoopUtil.java
@@ -65,7 +65,7 @@ public class EventLoopUtil {
                     try {
                         CpuAffinity.acquireCore();
                     } catch (Throwable t) {
-                        log.warn("Failed to acquire CPU core for thread {}", 
Thread.currentThread().getName(),
+                        log.warn("Failed to acquire CPU core for thread {} 
{}", Thread.currentThread().getName(),
                                 t.getMessage(), t);
                     }
                 });
diff --git 
a/pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/PulsarOffsetBackingStore.java
 
b/pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/PulsarOffsetBackingStore.java
index 774b8f1..b1338f8 100644
--- 
a/pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/PulsarOffsetBackingStore.java
+++ 
b/pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/PulsarOffsetBackingStore.java
@@ -67,7 +67,7 @@ public class PulsarOffsetBackingStore implements 
OffsetBackingStore {
         checkArgument(!isBlank(topic), "Offset storage topic must be 
specified");
         this.data = new HashMap<>();
 
-        log.info("Configure offset backing store on pulsar topic {} at cluster 
{}", topic);
+        log.info("Configure offset backing store on pulsar topic {}", topic);
     }
 
     void readToEnd(CompletableFuture<Void> future) {
diff --git 
a/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/coordination/impl/ResourceLockImpl.java
 
b/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/coordination/impl/ResourceLockImpl.java
index 55b420e..3a86aa3 100644
--- 
a/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/coordination/impl/ResourceLockImpl.java
+++ 
b/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/coordination/impl/ResourceLockImpl.java
@@ -206,7 +206,7 @@ public class ResourceLockImpl<T> implements ResourceLock<T> 
{
                             // We failed to revalidate the lock due to 
connectivity issue
                             // Continue assuming we hold the lock, until we 
can revalidate it, either
                             // on Reconnected or SessionReestablished events.
-                            log.warn("Failed to revalidate the lock at {}. 
Retrying later on reconnection", path,
+                            log.warn("Failed to revalidate the lock at {}. 
Retrying later on reconnection {}", path,
                                     ex.getCause().getMessage());
                         }
                     }