2012-01-11 7 views
0

私は単一のWindowsマシンにhadoopを設定するためにthis tutorialをフォローしています。 NameNodeサービスとJobTrackerサービスはそれぞれhttp://localhost:50070http://localhost:50030で動作しています。私は私の地図/ローカルのHadoopサーバー(right click on TestDriver.java > run as > Run on Hadoop)にドライバを軽減起動すると、私はfolowing出力があります。「マップからのキーの型の不一致」のためにhadoopでタスクが失敗する

12/01/11 20:04:11 WARN mapred.JobClient: Use GenericOptionsParser for parsing the arguments. Applications should implement Tool for the same. 
12/01/11 20:04:11 INFO mapred.FileInputFormat: Total input paths to process : 5 
12/01/11 20:04:11 INFO mapred.JobClient: Running job: job_201201112003_0001 
12/01/11 20:04:12 INFO mapred.JobClient: map 0% reduce 0% 

12/01/11 20:04:21 INFO mapred.JobClient: Task Id : attempt_201201112003_0001_m_000000_0, Status : FAILED 
java.io.IOException: Type mismatch in key from map: expected org.apache.hadoop.io.Text, recieved org.apache.hadoop.io.LongWritable 
    at org.apache.hadoop.mapred.MapTask$MapOutputBuffer.collect(MapTask.java:558) 
    at org.apache.hadoop.mapred.lib.IdentityMapper.map(IdentityMapper.java:37) 
    at org.apache.hadoop.mapred.MapRunner.run(MapRunner.java:50) 
    at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342) 
    at org.apache.hadoop.mapred.Child.main(Child.java:158) 

[Previous block is repeated 2 times, the task id changes] 

java.io.IOException: Job failed! 
    at org.apache.hadoop.mapred.JobClient.runJob(JobClient.java:1232) 
    at driverPkg.TestDriver.main(TestDriver.java:42) 

を、あなたは何が起こっているのアイデアを持っていますか?

答えて

1

これは、関連する行です:マップからキーで

型の不一致:予想org.apache.hadoop.io.Text、 はorg.apache.hadoop.io.LongWritable受け取っ

MapperはTextWritable出力(MapperクラスとMapメソッドの<>を参照)で定義されているようですが、あなたはLongWritableを出力しています。定義を変更するか、作成している内容を変更します。

関連する問題