You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by ji...@apache.org on 2022/07/30 10:52:16 UTC
[rocketmq] branch develop updated: [ISSUE #4729] Fix ambiguous error log (#4730)
This is an automated email from the ASF dual-hosted git repository.
jinrongtong pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
The following commit(s) were added to refs/heads/develop by this push:
new a94f8ff7a [ISSUE #4729] Fix ambiguous error log (#4730)
a94f8ff7a is described below
commit a94f8ff7aa574a7f25fe3755e56f340bd2190259
Author: Oliver <wq...@163.com>
AuthorDate: Sat Jul 30 18:51:56 2022 +0800
[ISSUE #4729] Fix ambiguous error log (#4730)
---
.../apache/rocketmq/namesrv/routeinfo/RouteInfoManager.java | 10 +++++-----
1 file changed, 5 insertions(+), 5 deletions(-)
diff --git a/namesrv/src/main/java/org/apache/rocketmq/namesrv/routeinfo/RouteInfoManager.java b/namesrv/src/main/java/org/apache/rocketmq/namesrv/routeinfo/RouteInfoManager.java
index 6f9cac4da..7a3bf1844 100644
--- a/namesrv/src/main/java/org/apache/rocketmq/namesrv/routeinfo/RouteInfoManager.java
+++ b/namesrv/src/main/java/org/apache/rocketmq/namesrv/routeinfo/RouteInfoManager.java
@@ -993,7 +993,7 @@ public class RouteInfoManager {
this.lock.readLock().unlock();
}
} catch (Exception e) {
- log.error("getAllTopicList Exception", e);
+ log.error("getSystemTopicList Exception", e);
}
return topicList;
@@ -1022,7 +1022,7 @@ public class RouteInfoManager {
this.lock.readLock().unlock();
}
} catch (Exception e) {
- log.error("getAllTopicList Exception", e);
+ log.error("getTopicsByCluster Exception", e);
}
return topicList;
@@ -1048,7 +1048,7 @@ public class RouteInfoManager {
this.lock.readLock().unlock();
}
} catch (Exception e) {
- log.error("getAllTopicList Exception", e);
+ log.error("getUnitTopics Exception", e);
}
return topicList;
@@ -1074,7 +1074,7 @@ public class RouteInfoManager {
this.lock.readLock().unlock();
}
} catch (Exception e) {
- log.error("getAllTopicList Exception", e);
+ log.error("getHasUnitSubTopicList Exception", e);
}
return topicList;
@@ -1101,7 +1101,7 @@ public class RouteInfoManager {
this.lock.readLock().unlock();
}
} catch (Exception e) {
- log.error("getAllTopicList Exception", e);
+ log.error("getHasUnitSubUnUnitTopicList Exception", e);
}
return topicList;