Github user danny0405 commented on a diff in the pull request:

    https://github.com/apache/storm/pull/2433#discussion_r153774053
  
    --- Diff: 
storm-server/src/main/java/org/apache/storm/daemon/supervisor/Supervisor.java 
---
    @@ -228,6 +257,51 @@ private void launchDaemon() {
             }
         }
     
    +    private void launchSupervisorThriftServer(Map conf) throws IOException 
{
    +        // validate port
    +        try {
    +            ServerSocket socket = new 
ServerSocket(ObjectReader.getInt(conf.get(Config.SUPERVISOR_THRIFT_PORT)));
    --- End diff --
    
    yeah


---

Reply via email to