storm__ReadClusterState.java.diff

diff --git storm-core/src/jvm/org/apache/storm/daemon/supervisor/ReadClusterState.java storm-core/src/jvm/org/apache/storm/daemon/supervisor/ReadClusterState.java
index 0fa60f129..dd4e8db78 100644
--- storm-core/src/jvm/org/apache/storm/daemon/supervisor/ReadClusterState.java
+++ storm-core/src/jvm/org/apache/storm/daemon/supervisor/ReadClusterState.java
@@ -145,6 +145,7 @@ public class ReadClusterState implements Runnable, AutoCloseable {
                 }
             }
             HashSet<Integer> allPorts = new HashSet<>(assignedPorts);
+            iSuper.assigned(allPorts);
             allPorts.addAll(slots.keySet());
             
             Map<Integer, Set<TopoProfileAction>> filtered = new HashMap<>();

storm__Supervisor.java.diff

diff --git storm-core/src/jvm/org/apache/storm/daemon/supervisor/Supervisor.java storm-core/src/jvm/org/apache/storm/daemon/supervisor/Supervisor.java
index a6adace80..d99726c42 100644
--- storm-core/src/jvm/org/apache/storm/daemon/supervisor/Supervisor.java
+++ storm-core/src/jvm/org/apache/storm/daemon/supervisor/Supervisor.java
@@ -233,7 +233,7 @@ public class Supervisor implements DaemonCommon, AutoCloseable {
     /**
      * start distribute supervisor
      */
-    private void launchDaemon() {
+    public void launchDaemon() {
         LOG.info("Starting supervisor for storm version '{}'.", VersionInfo.getVersion());
         try {
             Map<String, Object> conf = getConf();