У меня есть простой проект, соединяющий базу данных postgres со свечой. Мой проект выглядит так:
object Connector extends App {
runJdbcDatasetExample()
private def runJdbcDatasetExample(): Unit = {
val spark = SparkSession
.builder()
.appName("Spark SQL basic project")
.config("spark.master", "local")
.getOrCreate()
val jdbcDF = spark.read
.format("jdbc")
.option("url", "jdbc:mysql://localhost:5432")
.option("dbtable", "schema.tablename")
.option("user", "postgres")
.option("password", "root")
.load()
}
}
У меня есть база данных postgres, работающая на порту 5432. Однако, когда я запускаю проект, я получаю это:
Exception in thread "main" java.net.BindException: Can't assign requested address: Service 'sparkDriver' failed after 16 retries (on a random free port)! Consider explicitly setting the appropriate binding address for the service 'sparkDriver' (for example spark.driver.bindAddress for SparkDriver) to the correct binding address
Я не могу понятькак решить это. Благодарен за помощь!