问火花放电连接雪花面临的问题

EN

raise Py4JJavaError(
py4j.protocol.Py4JJavaError: An error occurred while calling o40.load.
: java.lang.NoClassDefFoundError: scala/$less$colon$less
    at net.snowflake.spark.snowflake.DefaultSource.shortName(DefaultSource.scala:44)
    at org.apache.spark.sql.execution.datasources.DataSource$.$anonfun$lookupDataSource$2(DataSource.scala:652)
    at org.apache.spark.sql.execution.datasources.DataSource$.$anonfun$lookupDataSource$2$adapted(DataSource.scala:652)
    at scala.collection.TraversableLike.$anonfun$filterImpl$1(TraversableLike.scala:304)

from pyspark.sql import SparkSession

sfoptions = {
"sfUrl" : URL
"sfUser" : USER
"sfPassword" : PASSWORD
"sfaccount" : ACCOUNT
}

query="SELECT COUNT(*) from table_name"

spark = SparkSession.builder.appName("demo").master("local").\
    config('spark.jars','../jars/spark-snowflake_2.13-2.10.0-spark_3.2.jar,../jars/snowflake-jdbc-3.13.9.jar').getOrCreate()

SNOWFLAKE_SOURCE_NAME="net.snowflake.spark.snowflake"

df=spark.read.format(SNOWFLAKE_SOURCE_NAME).options(**sfoptions).option("query",query).load()

df.show()