Ваш вопрос имеет ту же основную причину, что и эта .Этот вопрос породил этот билет против Scala.
Обновление: Эта ошибка исправлена в Scala 2.9.1 RC2
Вы можете обойти проблему, выполнивиспользуя Scala 2.8.1 (boo) или, как ни странно, определяя Mapper перед заданием.Следующие компиляции:
import org.apache.hadoop._
import org.apache.hadoop.io._
import org.apache.hadoop.conf._
import org.apache.hadoop.mapreduce._
class MyMapper extends Mapper[LongWritable,Text,Text,Text] {
override def map(key: LongWritable, value: Text, context: Mapper[LongWritable,Text,Text,Text]#Context) {
}
}
object MyJob {
def main(args:Array[String]) {
val job = new Job(new Configuration())
job.setMapperClass(classOf[MyMapper])
}
}