вызов отличного и карта вместе бросает NPE в искровой библиотеке

Я не уверен, если это ошибка, так что если вы делаете что-то вроде этого

// d:spark.RDD[String]
d.distinct().map(x => d.filter(_.equals(x)))

Вы получите Java NPE. Однако если вы делаетеcollect незамедлительно послеdistinct, все будет хорошо.

я используюискра 0.6.1.

Ответы на вопрос(2)

Ваш ответ на вопрос