Пытаться
def f(v: Iterable[Array[String]]): Int = {
val parsedDates = v.flatten.map(e => LocalDate.parse(e, formatter))
parsedDates.max.getDayOfYear - parsedDates.min.getDayOfYear
}
который выводит
val arrays = Iterable(Array("2014-10-10","2014-12-10"))
f(arrays) // res0: Int = 61
Попробуйте stackoverflow.com/questions/22592811/…
Ошибка: org.apache.spark.SparkException: задача не сериализуема