Yes, I already did like you tell, but I get an error in the
connection, and this doesn't make any sense.
java.io.IOException: Call to localhost/127.0.0.1:54311 failed on local
exception: java.io.EOFException
at org.apache.hadoop.ipc.Client.wrapException(Client.java:1107)
at org.apache.hadoop.ipc.Client.call(Client.java:1075)
at org.apache.hadoop.ipc.RPC$Invoker.invoke(RPC.java:225)
at org.apache.hadoop.mapred.$Proxy1.getProtocolVersion(Unknown Source)
at org.apache.hadoop.ipc.RPC.getProxy(RPC.java:396)
at org.apache.hadoop.ipc.RPC.getProxy(RPC.java:379)
at org.apache.hadoop.mapred.JobClient.createRPCProxy(JobClient.java:498)
at org.apache.hadoop.mapred.JobClient.init(JobClient.java:492)
at org.apache.hadoop.mapred.JobClient.<init>(JobClient.java:475)
at org.apache.hadoop.tools.JobProgression.status(JobProgression.java:38)
at org.apache.hadoop.tools.JobProgression.run(JobProgression.java:98)
at org.apache.hadoop.util.ToolRunner.run(ToolRunner.java:65)
at org.apache.hadoop.util.ToolRunner.run(ToolRunner.java:79)
at org.apache.hadoop.tools.JobProgression.main(JobProgression.java:69)
Caused by: java.io.EOFException
at java.io.DataInputStream.readInt(DataInputStream.java:375)
at
org.apache.hadoop.ipc.Client$Connection.receiveResponse(Client.java:804)
at org.apache.hadoop.ipc.Client$Connection.run(Client.java:749)
With failures, global counters are inaccurate; consider running with -i
Copy failed: java.lang.NullPointerException
at org.apache.hadoop.tools.JobProgression.status(JobProgression.java:45)
at org.apache.hadoop.tools.JobProgression.run(JobProgression.java:98)
at org.apache.hadoop.util.ToolRunner.run(ToolRunner.java:65)
at org.apache.hadoop.util.ToolRunner.run(ToolRunner.java:79)
at org.apache.hadoop.tools.JobProgression.main(JobProgression.java:69)
On 28 November 2012 17:44, Harsh J <ha...@cloudera.com> wrote:
> Mahesh,
>
> The JobTracker is not a user-end API, it is a service. You can't query
> it for its private objects as simply as that, and hence what you've
> suggested would not work.
>
> Pedro,
>
> To get a RunningJob instance from a String representing the JobID you
> need the JobClient class, and you can do like so:
>
> JobClient jc = new JobClient(jobConf);
> org.apache.hadoop.mapred.JobID jId =
> org.apache.hadoop.mapred.JobID.forName(jobIdString);
> RunningJob rJob = jc.getJob(jId);
> // Play with the rJob object as you want.
>
> On Wed, Nov 28, 2012 at 10:59 PM, Pedro Sá da Costa <psdc1...@gmail.com>
> wrote:
>> I have the jobId as a String, and from that I want to access the
>> RunningJob API for that jobId. I think that it is only possible to
>> access this API through the JobInProgress class, but maybe I'm wrong.
>> Is this true?
>>
>>
>> On 28 November 2012 17:24, Mahesh Balija <balijamahesh....@gmail.com> wrote:
>>> Hi Pedro,
>>>
>>> You can get the JobInProgress instance from JobTracker.
>>> JobInProgress getJob(JobID jobid);
>>>
>>> Best,
>>> Mahesh Balija,
>>> Calsoft Labs.
>>>
>>> On Wed, Nov 28, 2012 at 10:41 PM, Pedro Sá da Costa <psdc1...@gmail.com>
>>> wrote:
>>>>
>>>> I'm building a Java class and given a JobID, how can I get the
>>>> JobInProgress? Can anyone give me an example?
>>>>
>>>> --
>>>> Best regards,
>>>
>>>
>>
>>
>>
>> --
>> Best regards,
>
>
>
> --
> Harsh J
--
Best regards,
