protected void connect() {
    LOG.info("Connecting to collector...");
    try {
      conf.setStrings(UnixUserGroupInformation.UGI_PROPERTY_NAME,
                      new String[]{"hadoop", "hadoop"});
      rpcCollector =
            (UtilizationCollectorProtocol) RPC.getProxy(UtilizationCollectorProtocol.class,
                                             UtilizationCollectorProtocol.versionID,
                                             UtilizationCollector.getAddress(conf),
                                             conf);
    } catch (IOException e) {
      LOG.error("Cannot connect to UtilizationCollector server. Retry in " +
               DEFAULT_MIRROR_PERIOD + " milliseconds.");
      return;
    }
    LOG.info("Connection established");
  }
protected void connect ( ) { LOG . info ( "Connecting to collector..." ) ; try { conf . setStrings ( UnixUserGroupInformation . UGI_PROPERTY_NAME , new String [ ] { "hadoop" , "hadoop" } ) ; rpcCollector = ( UtilizationCollectorProtocol ) RPC . getProxy ( UtilizationCollectorProtocol . class , UtilizationCollectorProtocol . versionID , UtilizationCollector . getAddress ( conf ) , conf ) ; } catch ( IOException e ) { LOG . error ( "Cannot connect to UtilizationCollector server. Retry in " + DEFAULT_MIRROR_PERIOD + " milliseconds." ) ; return ; } LOG . info ( "Connection established" ) ; }
Make connection to the Collector