Spark Trino Connection

Question

目前我正在使用Spark 3.2.0与Trino 363。我试图连接到Trino，但我得到一个错误。错误信息如下:

线程"main"异常java.sql.SQLException:无法识别的连接属性'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()}")

谁能帮我指出这里出了什么问题?提前谢谢。

Answer 1

我可以在Trino 363上运行spark 3.2.0。我已经注释掉下面提到的行，并重新构建JDBC驱动程序。