-1

Spark の scala で次のコードを記述しました。

(inactiveIDs はRDD[(Int, Seq[String])]、persons は 、Broadcast[RDD[(Int, Seq[Event])]]Event は私が作成したクラスです)

val test = persons.value
  .map{tuple => (tuple._1, tuple._2
  .filter{event => inactiveIDs.filter(event2 => event2._1 == tuple._1).count() != 0})}

そして次のエラー：

java.lang.NullPointerException

何か案は？

4

1 に答える 1

0

解決策を見つけました。別のフィルター内で rdd をフィルター処理できません

于 2014-09-10T13:36:00.073 に答える