問(wèn)題描述
我正在使用
df.write.mode("append").jdbc("jdbc:mysql://ip:port/database", "table_name", properties)
插入到 MySQL 中的表中.
to insert into a table in MySQL.
此外，我在代碼中添加了 Class.forName("com.mysql.jdbc.Driver").
Also, I have added Class.forName("com.mysql.jdbc.Driver") in my code.
當(dāng)我提交 Spark 申請(qǐng)時(shí):
When I submit my Spark application:
spark-submit --class MY_MAIN_CLASS
--master yarn-client
--jars /path/to/mysql-connector-java-5.0.8-bin.jar
--driver-class-path /path/to/mysql-connector-java-5.0.8-bin.jar
MY_APPLICATION.jar
這種紗線客戶(hù)端模式對(duì)我有用.
This yarn-client mode works for me.
但是當(dāng)我使用紗線簇模式時(shí):
But when I use yarn-cluster mode:
spark-submit --class MY_MAIN_CLASS
--master yarn-cluster
--jars /path/to/mysql-connector-java-5.0.8-bin.jar
--driver-class-path /path/to/mysql-connector-java-5.0.8-bin.jar
MY_APPLICATION.jar
它不起作用.我也試過(guò)設(shè)置--conf":
It doens't work. I also tried setting "--conf":
spark-submit --class MY_MAIN_CLASS
--master yarn-cluster
--jars /path/to/mysql-connector-java-5.0.8-bin.jar
--driver-class-path /path/to/mysql-connector-java-5.0.8-bin.jar
--conf spark.executor.extraClassPath=/path/to/mysql-connector-java-5.0.8-bin.jar
MY_APPLICATION.jar
但仍然出現(xiàn)找不到適合 jdbc 的驅(qū)動(dòng)程序"錯(cuò)誤.
but still get the "No suitable driver found for jdbc" error.
推薦答案
有 3 種可能的解決方案，
There is 3 possible solutions,
- 您可能希望使用構(gòu)建管理器(Maven、SBT)組裝您的應(yīng)用程序，因此您無(wú)需在
spark-submitcli 中添加依賴(lài)項(xiàng). 您可以在
spark-submitcli 中使用以下選項(xiàng):
- You might want to assembly you application with your build manager (Maven,SBT) thus you'll not need to add the dependecies in your
spark-submitcli. You can use the following option in your
spark-submitcli :
--jars $(echo ./lib/*.jar | tr ' ' ',')
說(shuō)明:假設(shè)您在項(xiàng)目根目錄的 lib 目錄中擁有所有 jar，這將讀取所有庫(kù)并將它們添加到應(yīng)用程序提交中.
Explanation : Supposing that you have all your jars in a lib directory in your project root, this will read all the libraries and add them to the application submit.
您也可以嘗試在 SPARK_HOME/conf/spark 中配置這 2 個(gè)變量: 文件并將這些變量的值指定為jar文件的路徑.確保工作節(jié)點(diǎn)上存在相同的路徑.spark.driver.extraClassPath 和 spark.executor.extraClassPath-default.conf
You can also try to configure these 2 variables : spark.driver.extraClassPath and spark.executor.extraClassPath in SPARK_HOME/conf/spark-default.conf file and specify the value of these variables as the path of the jar file. Ensure that the same path exists on worker nodes.
這篇關(guān)于在 Spark 中找不到適合 jdbc 的驅(qū)動(dòng)程序的文章就介紹到這了，希望我們推薦的答案對(duì)大家有所幫助，也希望大家多多支持html5模板網(wǎng)！