java - Hadoop - 连接到 JobTracker

Question

我是 hadoop 的新手，我试图了解是否可以连接到远程或本地 jobtracker，我需要这个，因为我想确定 Hadoop 当前正在执行的任务，我正在尝试我发现的这个示例:

public class MyTracker {

    MyTracker(){
        try{
            inetAddress = new InetSocketAddress(InetAddress.getByName("localhost"), 50030);
        }
        catch(Exception e){
            e.printStackTrace();
        }
    }

    InetSocketAddress inetAddress = null;

    public static void main(String[] args) {

        MyTracker myTracker = new MyTracker();
        myTracker.createJobTracker();
    }

    public void createJobTracker(){

        Configuration conf = new Configuration();

        try {
            JobClient jobClient = new JobClient(inetAddress, conf);
            JobStatus[] activeJobs = jobClient.jobsToComplete();

            for(int i = 0 ; i < activeJobs.length; i++){
                System.out.println(activeJobs[i]);
            }
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
}

当我运行此代码时，出现此错误:

java.io.IOException: Call to localhost/127.0.0.1:50030 failed on local exception: java.io.EOFException
at org.apache.hadoop.ipc.Client.wrapException(Client.java:775)
at org.apache.hadoop.ipc.Client.call(Client.java:743)
at org.apache.hadoop.ipc.RPC$Invoker.invoke(RPC.java:220)
at org.apache.hadoop.mapred.$Proxy0.getProtocolVersion(Unknown Source)

请帮助我理解我所缺少的。

Answer 1

我能够运行它，它确实有一个版本不匹配加上这个

Jobtracker API error - Call to localhost/127.0.0.1:50030 failed on local exception: java.io.EOFException

因为当我应该按照该线程中的描述连接到端口 9001 时，我试图连接到端口 50030。

谢谢