Как получить данные из MySQL, используя pyspark - PullRequest
0 голосов
/ 15 октября 2018

У меня отсутствует зависимость от этого фрагмента:

from pyspark import SparkContext
from pyspark import HiveContext
sc = SparkContext()
sqlContext=HiveContext(sc)
df = sqlContext.read.format("jdbc").options(url="jdbc:mysql://localhost:3306/kmc",driver="com.mysql.jdbc.Driver", dbtable="src_account",user="XXXXXX", password="XXXXXX").load()    
df.show()

Я столкнулся с ошибкой ниже:

py4j.protocol.Py4JJavaError: Произошла ошибка при вызове o42.load,: java.lang.ClassNotFoundException: com.mysql.jdbc.Driver

Как это исправить?

...