storm-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bo...@apache.org
Subject [1/2] storm git commit: bugfix ConfigurableTopology completely overwrites preexisting config
Date Fri, 02 Nov 2018 19:10:17 GMT
Repository: storm
Updated Branches:
  refs/heads/master 00cd3d323 -> fb6308992


bugfix ConfigurableTopology completely overwrites preexisting config


Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/a88e4491
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/a88e4491
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/a88e4491

Branch: refs/heads/master
Commit: a88e4491c39e7dded5a16974ed2fcacc33892ae7
Parents: 730c1a3
Author: Julien Nioche <julien@digitalpebble.com>
Authored: Fri Oct 26 16:41:03 2018 +0100
Committer: Julien Nioche <julien@digitalpebble.com>
Committed: Fri Oct 26 16:41:03 2018 +0100

----------------------------------------------------------------------
 .../src/jvm/org/apache/storm/topology/ConfigurableTopology.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/storm/blob/a88e4491/storm-client/src/jvm/org/apache/storm/topology/ConfigurableTopology.java
----------------------------------------------------------------------
diff --git a/storm-client/src/jvm/org/apache/storm/topology/ConfigurableTopology.java b/storm-client/src/jvm/org/apache/storm/topology/ConfigurableTopology.java
index 088a382..3915198 100644
--- a/storm-client/src/jvm/org/apache/storm/topology/ConfigurableTopology.java
+++ b/storm-client/src/jvm/org/apache/storm/topology/ConfigurableTopology.java
@@ -86,7 +86,7 @@ public abstract class ConfigurableTopology {
             if (ret.size() == 1) {
                 Object confNode = ret.get("config");
                 if (confNode != null && confNode instanceof Map) {
-                    ret = (Map<String, Object>) ret;
+                    ret = (Map<String, Object>) confNode;
                 }
             }
         }


Mime
View raw message