Получение ошибки «Произошла ошибка при вызове o58.csv» при записи кадра данных Spark в файл CSV.Python

Программы на Python
Ответить Пред. темаСлед. тема
Anonymous
 Получение ошибки «Произошла ошибка при вызове o58.csv» при записи кадра данных Spark в файл CSV.

Сообщение Anonymous »

После использования df.write.csv для попытки экспортировать фрейм данных Spark в файл csv я получаю следующее сообщение об ошибке:
~\AppData\Local\Programs\Python\Python39\lib\site-packages\py4j\protocol.py
in get_return_value(answer, gateway_client, target_id, name

324 value = OUTPUT_CONVERTER[type](answer[2:], gateway_client)
325 if answer[1] == REFERENCE_TYPE:
326 raise Py4JJavaError(
327 "An error occurred while calling {0}{1}{2}.\n".
328 format(target_id, ".", name), value)

Py4JJavaError: An error occurred while calling o58.csv. :
org.apache.spark.SparkException: Job aborted.

Любая помощь приветствуется, поскольку я не могу понять, что здесь происходит, и несмотря на то, что это, казалось бы, простая операция.
РЕДАКТИРОВАТЬ: Публикуем весь код
from pyspark.sql.types import *
import pandasql as sqldf
import pyspark
from pyspark.sql import SparkSession
spark= SparkSession.builder.appName('SIAF').getOrCreate()
spark.conf.set('spark.sql.repl.eagerEval.enabled', True)
sc = spark.sparkContext
spark

spark_df=spark.read.csv(r'C:\Users\...\SIAF_2.csv',sep = ',', header=True, inferSchema=True)

df = spark_df.select(
[
"MENU",
"NOM_SISTEMA",
"DSC_GRP_USUARIO",
"NOM_USUARIO",
"NOM_FUNCIONARIO",
"IND_ATIVO",
"DAT_DESLIGAMENTO",
]
).where(
(spark_df["MENU"].isNotNull())
& (spark_df["IND_ATIVO"] == "S")
& (spark_df["DAT_DESLIGAMENTO"].isNull())
).sort(
spark_df["MENU"], ascending=True)

df.show(5)

df.write.csv(
"C:/Users/.../spark_test", mode="overwrite", sep=",", header=True
)



Подробнее здесь: https://stackoverflow.com/questions/701 ... a-spark-da
Реклама
Ответить Пред. темаСлед. тема

Быстрый ответ

Изменение регистра текста: 
Смайлики
:) :( :oops: :roll: :wink: :muza: :clever: :sorry: :angel: :read: *x)
Ещё смайлики…
   
К этому ответу прикреплено по крайней мере одно вложение.

Если вы не хотите добавлять вложения, оставьте поля пустыми.

Максимально разрешённый размер вложения: 15 МБ.

  • Похожие темы
    Ответы
    Просмотры
    Последнее сообщение

Вернуться в «Python»