注册号域名后如何建设公司网站,小程序商城开发,it运维服务商,共享设计平台报错信息#xff1a; py4j.protocol.Py4JJavaError: An error occurred while calling o33.load. : java.lang.ClassNotFoundException: com.mysql.jdbc.Driver 我的解决方法#xff1a; 这个报错就是提示你找不到jar包#xff0c;所以你需要去下载一个和你mysql版本匹配的j…报错信息 py4j.protocol.Py4JJavaError: An error occurred while calling o33.load. : java.lang.ClassNotFoundException: com.mysql.jdbc.Driver 我的解决方法 这个报错就是提示你找不到jar包所以你需要去下载一个和你mysql版本匹配的jdbc connector包下载地址https://downloads.mysql.com/archives/c-j/ 我的mysql最开始是8.0.36发现没有这个jar包所以就卸载了这个mysql然后重装了8.0.33安装教程https://blog.csdn.net/qq_42108074/article/details/134767511 都安装完成后将jar包拖进你spark路径/jars目录下就开始解决这个报错
方法一这个方法只针对pyspark我不清楚对后面全局是否有影响
在运行pyspark时主动加上你的jar包我的jar包目录是/usr/local/spark/jars/mysql-connector-java-8.0.33/mysql-connector-j.8.0.33.jar 所以我运行pyspark命令如下
./bin/pyspark --jars /usr/local/spark/jars/mysql-connector-java-8.0.33/mysql-connector-j-8.0.33.jar 测试代码 要先在mysql中添加数据库和表再运行下面这个代码 jdbcDFspark.read.format(jdbc).option(driver,com.mysql.cj.jdbc.Driver).option(url,jdbc:mysql://localhost:3306/spark).option(dbtable,student).option(user,root).option(password,你的密码).load()jdbcDF.show()运行结果 我认为这个方法是局部的也就是你每次打开都要加上jar包但是具体不知道对全局有没有用可以测试一下
方法二应该是全局有效的改名字
直接将你的jdbc connector里面的jar文件放在spark路径/jars下面原来的jar包名称是mysql-connector-j-8.0.33.jar我把他改成了mysql-connector-java-8.0.33.jar然后就可以了 复制到jars目录下去 就可以了修改后运行一下代码测试一下
