Существует проблема подключения MySQL с использованием jdbc () SparkSql - PullRequest
0 голосов
/ 23 июня 2019
def main(args: Array[String]): Unit = {
var url = "jdbc:mysql://localhost:3306/spark?useUnicode=true&characterEncoding=utf-8"
var table = "order"
var user = "root"
var password  = "123456"
var driver = "com.mysql.jdbc.Driver"
def main(args: Array[String]): Unit = {
  val sparkSession = SparkSession.builder().appName("orderCount").master("local").getOrCreate()
  val props = new Properties()
  props.put("user", user)
  props.put("password", password)
  val dsOrder = sparkSession.read.jdbc(url, table, props)
  dsOrder.show()
}

ошибка такая

введите описание изображения здесь введите описание изображения здесь

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...