Spark Trino 连接
Spark Trino Connection
目前我正在使用带有 Trino 363 的 Spark 3.2.0。我正在尝试连接到 Trino,但出现错误。报错信息如下。
Exception in thread "main" java.sql.SQLException: Unrecognized connection property 'url'
请在下面找到我正在使用的代码。
val sparkSession = SparkSession.builder().appName("Trino-Spark")
.master("local[*]")
.getOrCreate()
val properties = new Properties()
properties.setProperty("SSL", "true")
properties.setProperty("SSLVerification", "NONE")
properties.setProperty("user", "USERNAME")
properties.setProperty("password", "PWD")
val df = sparkSession.read.jdbc("jdbc:trino://HOST:PORT/hive", "hive.TABLE_NAME", properties)
println(s"Count: ${df.count()}")
请谁能帮我指出这里有什么问题。提前致谢。
我能够 运行 使用 Trino 363 启动 3.2.0。我已经注释掉下面提到的行并重新构建 JDBC 驱动程序。
目前我正在使用带有 Trino 363 的 Spark 3.2.0。我正在尝试连接到 Trino,但出现错误。报错信息如下。
Exception in thread "main" java.sql.SQLException: Unrecognized connection property 'url'
请在下面找到我正在使用的代码。
val sparkSession = SparkSession.builder().appName("Trino-Spark")
.master("local[*]")
.getOrCreate()
val properties = new Properties()
properties.setProperty("SSL", "true")
properties.setProperty("SSLVerification", "NONE")
properties.setProperty("user", "USERNAME")
properties.setProperty("password", "PWD")
val df = sparkSession.read.jdbc("jdbc:trino://HOST:PORT/hive", "hive.TABLE_NAME", properties)
println(s"Count: ${df.count()}")
请谁能帮我指出这里有什么问题。提前致谢。
我能够 运行 使用 Trino 363 启动 3.2.0。我已经注释掉下面提到的行并重新构建 JDBC 驱动程序。