Hi,
Sorry for the late response, but did you try connecting with the right
version of local Hadoop jar (0.20.205, same as your cluster)? Your
reported stacktrace like a RPC version mismatch issue between the
client and server.
On Fri, Jan 20, 2012 at 1:46 AM, Joseph McMahon <joe.mcma...@iswcorp.com> wrote:
> 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.
--
Harsh J
Customer Ops. Engineer
Cloudera | http://tiny.cloudera.com/about
