storm-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gov...@apache.org
Subject [storm] 03/05: replaced __system with Constants.SYSTEM_COMPONENT_ID
Date Wed, 22 May 2019 18:38:03 GMT
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 <david.andsager@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;
                 }
 


Mime
View raw message