Hi,

While debugging the YARN code, I come across following code snippet in YarnClientProtocolProvider.java

  @Override
  public ClientProtocol create(Configuration conf) throws IOException {
if (MRConfig.YARN_FRAMEWORK_NAME.equals(conf.get(MRConfig.FRAMEWORK_NAME))) {
      return new YARNRunner(conf);
    }
    return null;
  }

  @Override
  public ClientProtocol create(InetSocketAddress addr, Configuration conf)
      throws IOException {
    return create(conf);
  }

By the second API, it is clear that we can connect to the classic MR using client API (using JobClient(jt address, conf) and hence submit the job using the same job client instance.). However while initializing the cluster instance, the above functionality either creates a YarnRunner instance or returns null and hence client gets IOException. With this limitation we can't submit jobs to classic MR.

There is any reason behind providing this?

Please correct me if I understood wrongly.

--
Thanks&Regards,
Bh.V.S.Kamesh.

Reply via email to