Fix log format and swallow exception (apache#10252)

Co-authored-by: linjunhua <[email protected]>
blitznihar · Apr 18, 2021 · f6b0293 · f6b0293
1 parent ce42e5b
commit f6b0293
Show file tree

Hide file tree

Showing 3 changed files with 13 additions and 11 deletions.
diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/PulsarService.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/PulsarService.java
@@ -772,11 +772,10 @@ public Boolean get() {
             }
 
             // Start the task to publish resource usage, if necessary
-            if (config.getResourceUsageTransportClassName() != null
-              && config.getResourceUsageTransportClassName() != "") {
+            if (isNotBlank(config.getResourceUsageTransportClassName())) {
                 Class<?> clazz = Class.forName(config.getResourceUsageTransportClassName());
                 Constructor<?> ctor = clazz.getConstructor(PulsarService.class);
-                Object object = ctor.newInstance(new Object[] { this });
+                Object object = ctor.newInstance(new Object[]{this});
                 this.resourceUsageTransportManager = (ResourceUsageTransportManager) object;
             }
 

diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/resourcegroup/ResourceGroupService.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/resourcegroup/ResourceGroupService.java
@@ -292,7 +292,7 @@ public boolean incrementUsage(String tenantName, String nsName,
 
         // Expect stats to increase monotonically.
         if (incStats.bytes < 0 || incStats.messages < 0) {
-            String errMesg = String.format("incrementUsage on tenant={}, NS={}: bytes ({}) or mesgs ({}) is negative",
+            String errMesg = String.format("incrementUsage on tenant=%s, NS=%s: bytes (%s) or mesgs (%s) is negative",
                     tenantName, nsName, incStats.bytes, incStats.messages);
             throw new PulsarAdminException(errMesg);
         }

diff --git a/...r/src/main/java/org/apache/pulsar/broker/resourcegroup/ResourceUsageTransportManager.java b/...r/src/main/java/org/apache/pulsar/broker/resourcegroup/ResourceUsageTransportManager.java
@@ -97,7 +97,7 @@ public void run() {
                 byte[] bytes = buf.array();
                 producer.sendAsync(bytes).whenComplete((id, ex) -> {
                     if (null != ex) {
-                        LOG.error("Resource usage publisher: sending message ID {} error {}", id, ex);
+                        LOG.error("Resource usage publisher: sending message ID {} error", id, ex);
                     }
                     buf.release();
                 });
@@ -152,9 +152,11 @@ public void received(Reader<byte[]> reader, Message<byte[]> msg) {
                 });
 
             } catch (IllegalStateException exception) {
-                LOG.error("Resource usage reader: Error parsing incoming message {}", exception);
+                LOG.error("Resource usage reader: Error parsing incoming message", exception);
+                throw exception;
             } catch (Exception exception) {
-                LOG.error("Resource usage reader: Unknown exception while parsing message {}", exception);
+                LOG.error("Resource usage reader: Unknown exception while parsing message", exception);
+                throw exception;
             }
         }
 
@@ -192,8 +194,8 @@ private void createTenantAndNamespace() throws PulsarServerException, PulsarAdmi
             } catch (PulsarAdminException ex1) {
                 if (!(ex1 instanceof PulsarAdminException.ConflictException)) {
                     LOG.error("Unexpected exception {} when creating tenant {}", ex1, tenant);
-                    throw ex1;
                 }
+                throw ex1;
             }
         }
         List<String> nsList = admin.namespaces().getNamespaces(tenant);
@@ -203,8 +205,8 @@ private void createTenantAndNamespace() throws PulsarServerException, PulsarAdmi
             } catch (PulsarAdminException ex1) {
                 if (!(ex1 instanceof PulsarAdminException.ConflictException)) {
                     LOG.error("Unexpected exception {} when creating namespace {}", ex1, namespace);
-                    throw ex1;
                 }
+                throw ex1;
             }
         }
     }
@@ -218,7 +220,7 @@ public ResourceUsageTransportManager(PulsarService pulsarService) throws Excepti
             consumer = new ResourceUsageReader();
             pTask = new ResourceUsageWriterTask();
         } catch (Exception ex) {
-            LOG.error("Error initializing resource usage transport manager: {}", ex);
+            LOG.error("Error initializing resource usage transport manager", ex);
             throw ex;
         }
     }
@@ -265,7 +267,8 @@ public void close() throws Exception {
             pTask.close();
             consumer.close();
         } catch (Exception ex1) {
-            LOG.error("Error closing producer/consumer for resource-usage topic {}", ex1);
+            LOG.error("Error closing producer/consumer for resource-usage topic", ex1);
+            throw ex1;
         }
     }
 }