-1

我在 Spark 中用 scala 编写了以下代码：

（inactiveIDs 是 a RDD[(Int, Seq[String])]，persons 是 a 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 回答