#mysql #apache-spark
#mysql #apache-spark
Вопрос:
Хочу подключить mysql к spark. Он показывает эту ошибку :
Трассировка (последний последний вызов): Файл «/home/ewebcore/Desktop/spark_prgm/spark_sql_connect.py «, строка 10, в
df = SQLContext.read.format(«jdbc»).options( ошибка атрибута: объект ‘property’ не имеет атрибута ‘format’
from pyspark.sql import SQLContext
from pyspark.sql.session import SparkSession
from pyspark.sql.types import *
from pyspark import SparkContext, SparkConf, StorageLevel
df = SQLContext.read.format("jdbc").options(
url="jdbc:mysql://localhost:3306/Demo",
driver = "com.mysql.jdbc.Driver",
dbtable = "Bank",
user="root",
password="*******").load()`
Комментарии:
1. У меня такая же проблема. Это ваш собственный код или вы используете какой-то учебник? Я думаю, что мой просто неточный.
2. покажите мне код ur…