0
fatjarを作成するためにsbtアセンブリプラグインを使用しています。私は、デフォルトのハープ/スパークの一部であるが、新しいバージョンではいくつかのジャーが必要です。パッケージ化されたjarからクラスを優先する方法をスパークする
私はspark worker jvmに、デフォルトのhadoop/sparkディストリビューションではなく、私のfat jarファイルでパッケージ化されたバージョンを優先させたいと思っています。これどうやってするの?
あなたはあなたのウーファージャーに古いクラスを持っていますか? Sparkのどの部分を古いバージョンに置き換えたいですか? –
申し訳ありませんが、私は質問をする際に間違いを犯しました。私は新しい瓶が必要でしたが、火花は古いバージョンが付属しています。さて、私たちがスパーク・ジョブを提出すると、jvmにはsparkとhadoopからのジャーが入っていて、それからファット・ジャーから入っています。しかし、これらのjarファイルの古いバージョンは既にsparkからインクルードされているので、私のファットjarファイルに追加している新しいバージョンは破棄されます。私はsparkがこれらの新しいバージョンを使用し、デフォルトのspark/hadoopディストリビューションから来た矛盾するjarを破棄したい。要するに、クラスパスで後で追加された瓶を持っていきたいと思います。 –
スパークのどの部分を交換したいですか?どんな瓶が私たちについて話しているのですか? –