Использование JBDC для чтения файла sql в сборщике ошибок Scala Warehouse

Я пытаюсь прочитать файл MySQL, используя Spark Scala. Ниже приведен код, который я пытался

val dataframe_mysql = sqlContext.read.format("jdbc")
 .option("url","jdbc:mysql://xx.xx.xx.xx:xx")
 .option("driver", "com.mysql.jdbc.Driver")
 .option("dbtable", "schema.xxxx")
 .option("user", "xxxx").option("password", "xxxxx").load()

но я собираю ошибку пути хранилища следующим образом:

Путь к хранилищу: 'file:/C:/Users/ Владелец /eclipse-workspace/stProject/spark-ware‌ house/'. Исключение в потоке "main" java.lang.NullPointerException в org.apache.spark.sql.execution.datasources.jdbc.JDBCRDD$.res‌ olveTable(JDBCRDD.sc‌ ala:72) в org.apache.spark.sql. execute.datasources.jdbc.JDBCRelation‌.(JDBCRelation‌.scala:113) в org.apache.spark.sql.execution.datasources.jdbc.JdbcRelation‌ Provider.createRelat‌ ion(JdbcRelationProv‌ ider.scala:45) в

0 ответов

Другие вопросы по тегам