загрузить файл в интегрированную среду разработки - PullRequest
Новая
       30

загрузить файл в интегрированную среду разработки

0 голосов
/ 17 сентября 2018

У меня есть этот код: 

  def main(args: Array[String]): Unit = {

//  Creation of Spark Session
    implicit val sparkSession = SparkSession.builder().appName("seco_trial").getOrCreate()
    println("test")

    val df = sparkSession.read.format("csv").option("header", "true").load("D:/Userfiles/mir/Downloads/extract_sec_mav2.csv")

    println("test2")

строка, где я создаю val df, выдает мне следующую ошибку:

2018-09-17 14:27:24WARN FileStreamSink: 66 - Ошибка при поиске каталога метаданных.Исключение в потоке "основной"FileSystem.java:2667) [...]

Позволяет исключить неправильный путь как проблему.Мой файл правильно имеет расширение .csv

Подскажите, пожалуйста, в чем проблема?почему я не могу загрузить файл?

1 Ответ

0 голосов
/ 17 сентября 2018

Я не уверен, почему, но я должен добавить "fie: ///" впереди.

...