2017-07-17 3 views
0
Exception in thread "main" java.lang.RuntimeException: class org.apache.hadoop.mapreduce.lib.partition.KeyFieldBasedPartitioner not org.apache.hadoop.mapred.Partitioner 

at org.apache.hadoop.conf.Configuration.setClass(Configuration.java:2273) 

at org.apache.hadoop.mapred.JobConf.setPartitionerClass(JobConf.java:1165) 

at org.apache.hadoop.streaming.StreamJob.setJobConf(StreamJob.java:944) 

at org.apache.hadoop.streaming.StreamJob.run(StreamJob.java:128) 

at org.apache.hadoop.util.ToolRunner.run(ToolRunner.java:70) 

at org.apache.hadoop.util.ToolRunner.run(ToolRunner.java:84) 

at org.apache.hadoop.streaming.HadoopStreaming.main(HadoopStreaming.java:50) 

at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) 

at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) 

at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) 

at java.lang.reflect.Method.invoke(Method.java:498) 

at org.apache.hadoop.util.RunJar.run(RunJar.java:221) 

at org.apache.hadoop.util.RunJar.main(RunJar.java:136) 

がログからカウンターを取得しようとするとorg.apache.hadoop.mapreduce.lib.partition.KeyFieldBasedPartitioner ...Javaエラー:歴史をフェッチすることはできませんではないorg.apache.hadoop.mapred.Partitioner

ログ;不足しているジョブID

ませカウンタは、障害の原因について

スキャンログを...見つからない

履歴ログを取得することはできません。不足ジョブID

タスクログを取得できません。アプリケーションIDが見つかりません

keyfieldbasedpartitionerにパーティショナークラスを使用しようとするとこのエラーが発生します。私の入力と出力のフォーマットはrawvalueプロトコルで、出力はタブで区切られています。 誰もこれを見たことがありますか?助けてください。

+0

を使用する場合これは修正されましたあなたは、このジョブを実行しようとしている方法を投稿することができますか? –

答えて

0

私は

--partitioner", "org.apache.hadoop.mapred.lib.KeyFieldBasedPartitioner",

関連する問題