Как устранить ошибку аутентификации по паролю для ошибки пользователя «postgres» для этого кода spark-scala - PullRequest
0 голосов
/ 03 октября 2019

Я пытаюсь прочитать данные на искровом фрейме данных через postgre db, я даю правильные учетные данные для этой базы данных, но все же получаю ошибку в пароле. Аутентификация

Пробовал, давая URL-адреса postgres в разных форматахи задание пароля по умолчанию для Postgre

def readFromDb (): DataFrame = {

val readFromDb_DF=sqlContext.read
  .format("jdbc")
  .option("url", "jdbc:postgresql://localhost/ReadAndWrite_DB?user=postgres&password=vishan.756")
  .option("dbtable", "employee")
  .option("user","postgres")
  .option("password","vishan.756")
  .option("driver","org.postgresql.Driver")
  .load()
  .createOrReplaceTempView("Temp_Employee")

val emp_Data_DF=sqlContext.sql("""select * from Temp_Employee""")

emp_Data_DF

}

Ожидается, что данные будут считаны в кадр данных readFromDb_DF изpostgres ReadAndWrite_DB

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...