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()
}
ошибка такая
введите описание изображения здесь
введите описание изображения здесь