I am trying to run a M/R job remotely on a HBAse table.

I have added the conf.set("fs.default.name","hdfs://10.0.0.3:60000") to the
code hence now it does go to the cluster there I see the error

WARN org.apache.hadoop.ipc.HBaseServer: IPC Server listener on 60000:
readAndProcess threw exception java.io.EOFException. Count of bytes read: 0

jjava.io.EOFException


        at java.io.DataInputStream.readFully(DataInputStream.java:180)
        at 
org.apache.hadoop.io.DataOutputBuffer$Buffer.write(DataOutputBuffer.java:63)
        at 
org.apache.hadoop.io.DataOutputBuffer.write(DataOutputBuffer.java:101)
        at org.apache.hadoop.io.UTF8.readChars(UTF8.java:216)
        at org.apache.hadoop.io.UTF8.readString(UTF8.java:208)
        at 
org.apache.hadoop.io.ObjectWritable.readObject(ObjectWritable.java:179)
        at 
org.apache.hadoop.io.ObjectWritable.readObject(ObjectWritable.java:171)
        at 
org.apache.hadoop.hbase.ipc.HBaseServer$Connection.processHeader(HBaseServer.java:966)
        at 
org.apache.hadoop.hbase.ipc.HBaseServer$Connection.readAndProcess(HBaseServer.java:950)
        at 
org.apache.hadoop.hbase.ipc.HBaseServer$Listener.doRead(HBaseServer.java:522)
        at 
org.apache.hadoop.hbase.ipc.HBaseServer$Listener$Reader.run(HBaseServer.java:316)
        at 
java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
        at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
        at java.lang.Thread.run(Thread.java:662)

and at the client side I see

Exception in thread "main" java.io.IOException: Call to
/10.0.0.3:60000failed on local exception: java.io.IOException:
Connection reset by peer

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 $Proxy4.getProtocolVersion(Unknown Source)

at org.apache.hadoop.ipc.RPC.getProxy(RPC.java:359)

at org.apache.hadoop.hdfs.DFSClient.createRPCNamenode(DFSClient.java:106)

at org.apache.hadoop.hdfs.DFSClient.<init>(DFSClient.java:207)

        etc



I am pretty sure I am missing configuration pieces to achieve the same..What
could be those ?

Reply via email to