jjzjj

SerializationFactory

全部标签

java - 调用 InputSplit 的 getClass() 时来自 Hadoop 的 JobSplitWriter/SerializationFactory 的 NullPointerException

我得到一个NullPointerException启动MapReduce时工作。它被SerializationFactory抛出的getSerializer()方法。我正在使用自定义InputSplit,InputFormat,RecordReader和MapReduce值类。我知道在我的InputFormat创建拆分后一段时间后会抛出错误类,但在创建RecordReader之前.据我所知,它是在“清理暂存区”消息之后直接发生的。通过检查堆栈跟踪指示的位置中的Hadoop源,看起来错误发生在getSerialization()时。收到空值Class指针。JobClient的writeN