fatjarでパックされ、EMR Hadoopクラスタで実行されているスケーリングジョブがあります。最近、マップ内にDynamoDB接続が必要な新機能が追加されました。しかし、すぐにマッパーがDynamoDBの初期化に達すると、それは次の例外スロー: Error in configuring object
at org.apache.hadoop.util.ReflectionUtils
YARNを使用している間にZeppelinでScaldingを処理しようとしています。私は、文書hereの手順に従ってインタープリタを構築し、クラスパスの上書きを設定しました。ローカルモードで実行すると、コードが正しく実行されます。私はYARNを経由して私のクラスタ上で実行した場合しかし、私の仕事はして失敗: Error: java.lang.ClassNotFoundException: cas
私は単純な単語カウント型のものを行うためにスケーリングを使用しています。部分関数を使ってタプルを展開するとエラーが出ます。正確なエラーメッセージは次のとおりです。 Error:(15, 14) missing parameter type for expanded function
The argument types of an anonymous function must be fully