Details
-
Bug
-
Status: Closed
-
Major
-
Resolution: Fixed
-
None
-
None
-
None
Description
TaskReport[] rep = jc.getMapTaskReports(jobId);
I get de/serialization problems:
This change suggested by Owen fixes it:
- new ObjectWritable(diagnostics).write(out);
+ WritableUtils.writeStringArray(out, diagnostics);
- ObjectWritable wrapper = new ObjectWritable();
- wrapper.readFields(in);
- diagnostics = (String[])wrapper.get();
+ diagnostics = WritableUtils.readStringArray(in);
java.lang.NullPointerException
at org.apache.hadoop.io.ObjectWritable.readObject(ObjectWritable.java:174)
at org.apache.hadoop.io.ObjectWritable.readFields(ObjectWritable.java:59)
at org.apache.hadoop.mapred.TaskReport.readFields(TaskReport.java:64)
at org.apache.hadoop.io.ObjectWritable.readObject(ObjectWritable.java:225)
at org.apache.hadoop.io.ObjectWritable.readObject(ObjectWritable.java:163)
at org.apache.hadoop.io.ObjectWritable.readObject(ObjectWritable.java:210)
at org.apache.hadoop.io.ObjectWritable.readFields(ObjectWritable.java:59)
at org.apache.hadoop.ipc.Client$Connection.run(Client.java:256)
2006-09-19 08:44:31,059 WARN ipc.Server (Server.java:run(493)) - handler output error
java.nio.channels.ClosedChannelException