Я работаю над тем, чтобы на моей машине работал мост hadoop / scala, и когда я настраиваю задание, я получаю следующую ошибку от компилятора.
[error] found : java.lang.Class[org.apache.hadoop.mapred.TextInputFormat (classOf[org.apache.hadoop.mapred.TextInputFormat])
[error] required: java.lang.Class[_ <: org.apache.hadoop.mapred.InputFormat]
[error] conf setInputFormat classOf[TextInputFormat]
Я не уверен, что делать дальше, учитывая, что TextInputFormat действительно реализует InputFormat.
(см .: http://hadoop.apache.org/mapreduce/docs/current/api/org/apache/hadoop/mapred/TextInputFormat.html)
Есть ли вероятность того, что это не работает из-за проблемы необработанного типа, когда TextInputFormat реализует InputFormat с определенным набором параметров?
Спасибо за любую помощь, которую вы можете предоставить.
РЕДАКТИРОВАТЬ: также, для строки с ошибкой, conf является JobConf, является одним из них http://hadoop.apache.org/common/docs/current/api/org/apache/hadoop/mapred/JobConf.html