You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by go...@apache.org on 2019/05/22 18:38:03 UTC
[storm] 03/05: replaced __system with Constants.SYSTEM_COMPONENT_ID
This is an automated email from the ASF dual-hosted git repository.
govind pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/storm.git
commit 969fea6562e137957001a718864e65ece15f272b
Author: dandsager <da...@verizonmedia.com>
AuthorDate: Mon May 20 11:55:30 2019 -0500
replaced __system with Constants.SYSTEM_COMPONENT_ID
---
storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java b/storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java
index d1e37a8..0f662de 100644
--- a/storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java
+++ b/storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java
@@ -4182,7 +4182,7 @@ public class Nimbus implements Iface, Shutdownable, DaemonCommon {
if (topoPageInfo.get_id_to_bolt_agg_stats().isEmpty()) {
Map<String, Bolt> bolts = topology.get_bolts();
for (String boltName : bolts.keySet()) {
- if ((!includeSys && Utils.isSystemId(boltName)) || boltName.equals("__system")) {
+ if ((!includeSys && Utils.isSystemId(boltName)) || boltName.equals(Constants.SYSTEM_COMPONENT_ID)) {
continue;
}