You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by mm...@apache.org on 2022/09/26 18:52:25 UTC
[pulsar] branch master updated: Set log level to `warn` when topic policy reader occurs AlreadyClosedException. (#17841)
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 e0920648a9f Set log level to `warn` when topic policy reader occurs AlreadyClosedException. (#17841)
e0920648a9f is described below
commit e0920648a9f44f4e3760ec85083be8cc1d96ea58
Author: Jiwei Guo <te...@apache.org>
AuthorDate: Tue Sep 27 02:52:17 2022 +0800
Set log level to `warn` when topic policy reader occurs AlreadyClosedException. (#17841)
---
.../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 f5db6e2311b..b3a5e8c2b8b 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
@@ -395,7 +395,7 @@ public class SystemTopicBasedTopicPoliciesService implements TopicPoliciesServic
} else {
Throwable cause = FutureUtil.unwrapCompletionException(ex);
if (cause instanceof PulsarClientException.AlreadyClosedException) {
- log.error("Read more topic policies exception, close the read now!", ex);
+ log.warn("Read more topic policies exception, close the read now!", ex);
cleanCacheAndCloseReader(
reader.getSystemTopic().getTopicName().getNamespaceObject(), false);
} else {