This is an automated email from the ASF dual-hosted git repository. rgao pushed a commit to branch branch-2.9 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 8279db990479d5ebc8c00c3bf7dde4cdcb05643d Author: Qiang Zhao <[email protected]> AuthorDate: Wed Feb 16 14:05:53 2022 +0800 Fix the wrong parameter in the log. (#14309) ### Motivation Bad parameters in the log will always print "null", which can confuse users. ### Modifications - Correct exception parameter. (cherry picked from commit 9b003f96f1deb8e02a1654e30fbddd211d787e8e) --- .../pulsar/broker/service/SystemTopicBasedTopicPoliciesService.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/SystemTopicBasedTopicPoliciesService.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/SystemTopicBasedTopicPoliciesService.java index 838edfe..ddf926d 100644 --- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/SystemTopicBasedTopicPoliciesService.java +++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/SystemTopicBasedTopicPoliciesService.java @@ -323,7 +323,7 @@ public class SystemTopicBasedTopicPoliciesService implements TopicPoliciesServic reader.readNextAsync().whenComplete((msg, e) -> { if (e != null) { log.error("[{}] Failed to read event from the system topic.", - reader.getSystemTopic().getTopicName(), ex); + reader.getSystemTopic().getTopicName(), e); future.completeExceptionally(e); readerCaches.remove(reader.getSystemTopic().getTopicName().getNamespaceObject()); policyCacheInitMap.remove(reader.getSystemTopic().getTopicName().getNamespaceObject());
