При загрузке данных Json в DataFrame я получаю только столбец _corrupt_record
. Я пробовал Ниже оба варианта, но существует та же проблема, пожалуйста, руководство.
val df = spark.read.option("multiline", "true").json("<file>")
val df = spark.read.json(spark.sparkContext.wholeTextFiles("file.json").values)