[incubator-pulsar] branch master updated: Issue 2121: Improve logging around "Namespace not served by this instance" (#2183)

[sijie]

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/incubator-pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new f0024d2  Issue 2121: Improve logging around "Namespace not served by 
this instance" (#2183)
f0024d2 is described below

commit f0024d2d95b947f1e2ac09165133ed1fde146cb9
Author: Sijie Guo <guosi...@gmail.com>
AuthorDate: Tue Jul 17 18:02:28 2018 -0700

    Issue 2121: Improve logging around "Namespace not served by this instance" 
(#2183)
    
    ### Motivation
    
    Fixes #2121. Improve the logging around "namespace not served by this 
instance" to make things clearer.
    
     ### Changes
    
    Improve the logging to say "namespace bundle for topic not served by", 
rahter than "namespace not served by"
---
 .../src/main/java/org/apache/pulsar/broker/service/BrokerService.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java
 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java
index 5bdf812..741afbf 100644
--- 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java
+++ 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java
@@ -934,8 +934,8 @@ public class BrokerService implements Closeable, 
ZooKeeperCacheListener<Policies
         }
 
         if (!ownedByThisInstance) {
-            String msg = String.format("Namespace not served by this instance. 
Please redo the lookup. "
-                    + "Request is denied: namespace=%s", 
topicName.getNamespace());
+            String msg = String.format("Namespace bundle for topic (%s) not 
served by this instance. Please redo the lookup. "
+                    + "Request is denied: namespace=%s", topic, 
topicName.getNamespace());
             log.warn(msg);
             throw new RuntimeException(new ServiceUnitNotReadyException(msg));
         }