src/main/java/com/uber/rss/clients/RecordSocketReadClient.java [49:62]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public DownloadServerVerboseInfo connect() {
        try {
            ConnectDownloadResponse connectDownloadResponse = dataBlockSocketReadClient.connect();
            DownloadServerVerboseInfo downloadServerVerboseInfo = new DownloadServerVerboseInfo();
            downloadServerVerboseInfo.setId(connectDownloadResponse.getServerId());
            downloadServerVerboseInfo.setRunningVersion(connectDownloadResponse.getRunningVersion());
            downloadServerVerboseInfo.setMapTaskCommitStatus(connectDownloadResponse.getMapTaskCommitStatus());
            return downloadServerVerboseInfo;
        } catch (RuntimeException ex) {
            logger.warn(String.format("Failed to connect %s", this), ex);
            close();
            throw ex;
        }
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



src/main/java/com/uber/rss/clients/ShuffleDataSocketReadClient.java [49:62]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  public DownloadServerVerboseInfo connect() {
    try {
      ConnectDownloadResponse connectDownloadResponse = dataBlockSocketReadClient.connect();
      DownloadServerVerboseInfo downloadServerVerboseInfo = new DownloadServerVerboseInfo();
      downloadServerVerboseInfo.setId(connectDownloadResponse.getServerId());
      downloadServerVerboseInfo.setRunningVersion(connectDownloadResponse.getRunningVersion());
      downloadServerVerboseInfo.setMapTaskCommitStatus(connectDownloadResponse.getMapTaskCommitStatus());
      return downloadServerVerboseInfo;
    } catch (RuntimeException ex) {
      logger.warn(String.format("Failed to connect %s", this), ex);
      close();
      throw ex;
    }
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -