Spark: Задача для каждой части не сериализуема
#scala #apache-spark #apache-spark-sql #lucene Вопрос: В соответствии с плиткой Task not serializable , к которой я клоню foreachPartition . Ниже приведен фрагмент кода: documents.repartition(1).foreachPartition( allDocuments =gt; { val luceneIndexWriter: IndexWriter…