java.sql.SQLException: [Simba] [SparkJDBCDriver] (500151) Ошибка установки / закрытия сеанса: ошибка открытого сеанса - PullRequest
0 голосов
/ 13 декабря 2018

я хочу соединить sparksql с jdbc в коде

   import jaydebeapi

    conn = jaydebeapi.connect('com.simba.spark.jdbc41.Driver',"jdbc:spark://localhost:10000/default;AuthMech=3;SSL=0",{'user': 'spark', 'password': "di6'gnr"},'/hdfs/dev/scripts/pyspark/drivers/SparkJDBC41.jar',)
    curs = conn.cursor()

    curs.execute("select * from CUSTOMER")
    curs.fetchall()

    curs.close()
    conn.close()

введите описание изображения здесь

...