錯誤:Unable to initialize MapOutputCollector的解決辦法
我是因為把我自己定義的bean當成key從map端傳到reduce端了,但是我沒有針對實現的WritableComparable介面,而是實現的Writable和Comparable介面(講道理WritableComparable介面也是對這兩個介面做了整合,為什麼我分別實現就不行呢?),然後報了這個錯誤。
這種錯誤有兩種原因,一個是網上說的導包錯誤,比如Text是要導hadoop.io下面的,而不是其它的包,第二個就是map端傳出來的key要求是可比較的,實現WritableComparable介面,重寫compareto方法,不然map端的shuffle無法進行。