DataFrame使用mysql数据

错误提示:

 Exception in thread "main" java.sql.SQLException: No suitable driver found for jdbc:mysql://localhost:3306/sparkSql?user=root&password=123 


配置驱动的时候有两个大坑

1.首先你要在SPARK_CLASSSPATH中加入mysql的驱动。

2.如果你已经在CP中加入了驱动,又在spark-submit的时候使用--driver-class-path    或是在代码的spark-conf中使用spark.driver.extraClassPath属性都会报错。


之后就可以轻松调用API操作Mysql的数据啦

val mysqlData = sqlContext.jdbc("jdbc:mysql://master:3306/sparkSql?user=root&password=123","people")
mysqlData.show()

原文地址:https://www.cnblogs.com/zhangyunlin/p/6168192.html