This is an automated email from the ASF dual-hosted git repository. guangning pushed a commit to branch branch-2.5 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit a8fc1c5c38b945240d5e425cc3be7f0926b19022 Author: ntysdd <[email protected]> AuthorDate: Thu Jan 23 12:40:14 2020 +0800 Fix issue 5505 (#6060) --- .../org/apache/pulsar/common/policies/data/TopicStats.java | 14 ++++++++++++-- 1 file changed, 12 insertions(+), 2 deletions(-) diff --git a/pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/TopicStats.java b/pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/TopicStats.java index 6f7fcc1..9962fa9 100644 --- a/pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/TopicStats.java +++ b/pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/TopicStats.java @@ -121,7 +121,12 @@ public class TopicStats { } } else { for (String subscription : stats.subscriptions.keySet()) { - this.subscriptions.get(subscription).add(stats.subscriptions.get(subscription)); + if (this.subscriptions.get(subscription) != null) { + this.subscriptions.get(subscription).add(stats.subscriptions.get(subscription)); + } else { + SubscriptionStats subscriptionStats = new SubscriptionStats(); + this.subscriptions.put(subscription, subscriptionStats.add(stats.subscriptions.get(subscription))); + } } } if (this.replication.size() != stats.replication.size()) { @@ -131,7 +136,12 @@ public class TopicStats { } } else { for (String repl : stats.replication.keySet()) { - this.replication.get(repl).add(stats.replication.get(repl)); + if (this.replication.get(repl) != null) { + this.replication.get(repl).add(stats.replication.get(repl)); + } else { + ReplicatorStats replStats = new ReplicatorStats(); + this.replication.put(repl, replStats.add(stats.replication.get(repl))); + } } } return this;
