Я использую spark-core версии 2.0.1 со Scala 2.11. У меня есть простой код для чтения CSV-файла, который имеет \ escapes. val myDA = spark.read .option("quote",null) .schema(mySchema) .csv(filePath) Согласно документации \...

Мы используем программу чтения CSV Spark для чтения CSV-файла для преобразования в DataFrame, и мы запускаем задание на yarn-client , оно отлично работает в локальном режиме. Мы отправляем задание искры в edge node . Но когда мы помещаем файл...