【发布时间】:2017-01-18 17:59:55
【问题描述】:
我正在从 1.6 升级到 spark 2,但在读取 CSV 文件时遇到问题。在 spark 1.6 中,我会在 CSV 文件中读取类似的内容。
val df = sqlContext.read.format("com.databricks.spark.csv")
.option("header", "true")
.load(fileName)
现在我使用文档中给出的以下代码:
val df = spark.read
.option("header", "true")
.csv(fileName)
这会导致运行时出现如下错误:
"Exception in thread "main" java.lang.RuntimeException: Multiple sources found for csv (org.apache.spark.sql.execution.datasources.csv.CSVFileFormat, com.databricks.spark.csv.DefaultSource15), please specify the fully qualified class name."
我认为这是因为我仍然有 spark-csv 依赖项,但是我删除了该依赖项并重新构建了应用程序,但仍然遇到相同的错误。删除后如何仍然找到 databricks 依赖项?
【问题讨论】:
标签: csv apache-spark apache-spark-2.0 databricks