Использование 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) в