错误提示:
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()