I tried connecting to a 0.20.205 hadoop cluster and use the methods on
JobClient to query the JobTracker status and get a list of jobs, etc. Much
like the JobTracker Web UI shows. Code is:
Configuration hadoopConf = new Configuration();
hadoopConf.set("fs.default.name", "hdfs://dev1:8020");
hadoopConf.set("mapred.job.tracker", "dev1:8021");
JobConf conf = new JobConf(hadoopConf);
jobClient = new JobClient(conf);
I get an exception on the last line:
java.io.IOException: Call to dev1/192.168.10.101:8021 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.$Proxy8.getProtocolVersion(Unknown Source)
at org.apache.hadoop.ipc.RPC.getProxy(RPC.java:359)
at org.apache.hadoop.mapred.JobClient.createRPCProxy(JobClient.java:429)
at org.apache.hadoop.mapred.JobClient.init(JobClient.java:423)
at org.apache.hadoop.mapred.JobClient.<init>(JobClient.java:410)
Any help would be appreciated.
