3

私はFtelというバッグを持っています。describe Ftel;次の結果になります-

Ftel: {billVal:int, billCount:int}

Ftel からのダンプの例は次のとおりです。

(20,1)
(5,1)
(5,1)
(10,1)
...
etc.

コマンドを使用して上記のバッグをグループ化しましたGtel = group Ftel by billVal;

今、Dump Gtel;次のエラーをスローします-

豚のスタック トレース

ERROR 1066: Unable to open iterator for alias Gtel

org.apache.pig.impl.logicalLayer.FrontendException: ERROR 1066: Unable to open iterator for alias Gtel
at org.apache.pig.PigServer.openIterator(PigServer.java:765)
at org.apache.pig.tools.grunt.GruntParser.processDump(GruntParser.java:615)
at    
org.apache.pig.tools.pigscript.parser.PigScriptParser.parse(PigScriptParser.java:303)
at org.apache.pig.tools.grunt.GruntParser.parseStopOnError(GruntParser.java:168)
at org.apache.pig.tools.grunt.GruntParser.parseStopOnError(GruntParser.java:144)
at org.apache.pig.tools.grunt.Grunt.run(Grunt.java:76)
at org.apache.pig.Main.run(Main.java:455)
at org.apache.pig.Main.main(Main.java:107)
Caused by: java.io.IOException: Job terminated with anomalous status FAILED
at org.apache.pig.PigServer.openIterator(PigServer.java:755)

この問題の原因はわかりません。助けてください。

ありがとう！

4

2 に答える 2

0

将来の検索者へのヒントとして、クラスターで正常に動作するスクリプトで同じ問題に遭遇しました。

問題は、マッパーの出力がまだ圧縮されていることでした。スクリプトでこれらのオプションをコメントアウトすると、修正されました。

SET mapred.compress.map.output 'true';
SET mapred.map.output.compression.codec 'org.apache.hadoop.io.compress.GzipCodec';
于 2013-03-05T01:25:14.607 に答える
0

それは今動作します...私はちょうどからFtelを変更しました

Ftel: {billVal:int, billCount:int}

に

Ftel: {billVal:chararray, billCount:int}

グループキーがchararrayの場合にのみグループ化が機能するようです。誰かが理由を知っていますか??

于 2012-11-05T12:25:37.993 に答える