вызов отличного и карта вместе бросает NPE в искровой библиотеке
Я не уверен, если это ошибка, так что если вы делаете что-то вроде этого
// d:spark.RDD[String]
d.distinct().map(x => d.filter(_.equals(x)))
Вы получите Java NPE. Однако если вы делаетеcollect
незамедлительно послеdistinct
, все будет хорошо.
я используюискра 0.6.1.