雪花Scala连接器(雪公园)

Question

我对scala很陌生，并尝试使用雪花雪花公园scala库在scala中创建雪花连接器。

这是我的简单代码

package com.abc.commons.rest.snowflake
import com.snowflake.snowpark._
import com.snowflake.snowpark.functions._

object ScalaConnector {
  def main(args: Array[String]): Unit = {
    // Replace the <placeholders> below.
    val configs = Map (
      "URL" -> "https://xxx.snowflakecomputing.com:443",
      "USER" -> "xxx",
      "PASSWORD" -> "xxx",
      "ROLE" -> "xxx",
      "WAREHOUSE" -> "xxx",
      "DB" -> "xxx",
      "SCHEMA" -> "xxx"
    )
    val session = Session.builder.configs(configs).create
    session.sql("show tables").show()
    session.close();
  }
}

我提供了正确的凭据，然后在IntelliJ中运行上述代码时，我会看到以下错误：

Exception in thread "main" java.lang.ExceptionInInitializerError
    at com.abc.commons.rest.snowflake.ScalaConnector$.main(ScalaConnector.scala:17)
    at com.abc.commons.rest.snowflake.ScalaConnector.main(ScalaConnector.scala)
Caused by: java.lang.NullPointerException
    at com.snowflake.snowpark.Session$.getActiveSession(Session.scala:1204)
    at com.snowflake.snowpark.SnowparkClientException.<init>(SnowparkClientException.scala:15)
    at com.snowflake.snowpark.internal.ErrorMessage$.createException(ErrorMessage.scala:380)
    at com.snowflake.snowpark.internal.ErrorMessage$.MISC_SCALA_VERSION_NOT_SUPPORTED(ErrorMessage.scala:340)
    at com.snowflake.snowpark.internal.Utils$.checkScalaVersionCompatibility(Utils.scala:243)
    at com.snowflake.snowpark.internal.Utils$.checkScalaVersionCompatibility(Utils.scala:233)
    at com.snowflake.snowpark.Session$.<init>(Session.scala:1129)
    at com.snowflake.snowpark.Session$.<clinit>(Session.scala)
    ... 2 more

我在libraryDependencies中使用的build.sbt

"com.snowflake" % "snowpark" % "1.4.0"

有人能指出我代码中的问题吗？

Answer 1

代码没有问题，您只是使用不受支持的Scala版本。从你的堆叠痕迹来看：

MISC_SCALA_VERSION_NOT_SUPPORTED

我们只支持Scala2.12，正如解释的这里。