火花Trino连接

Question

目前，我正在使用Spark3.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驱动程序。

Trino 363 JDBC驱动程序