scala - 使用 Presto 驱动程序时后端 scala 无法加载数据帧_java.sql.Exception
问题描述
这是测试中断的地方。
var df = spark.read.format("jdbc")
.option("url", url_ )
.option("dbtable", dbtable_ )
.option("driver", "com.facebook.presto.jdbc.PrestoDriver")
.load()
我得到的异常消息:即使使用 prestosql 版本 326 JDBC 驱动程序也会引发相同的消息。
java.sql.SQLException: Unsupported type ARRAY
at org.apache.spark.sql.execution.datasources.jdbc.JdbcUtils$.org$apache$spark$sql$execution$datasources$jdbc$JdbcUtils$$getCatalystType(JdbcUtils.scala:251)
at org.apache.spark.sql.execution.datasources.jdbc.JdbcUtils$$anonfun$8.apply(JdbcUtils.scala:316)
at org.apache.spark.sql.execution.datasources.jdbc.JdbcUtils$$anonfun$8.apply(JdbcUtils.scala:316)
at scala.Option.getOrElse(Option.scala:121)
at org.apache.spark.sql.execution.datasources.jdbc.JdbcUtils$.getSchema(JdbcUtils.scala:315)
at org.apache.spark.sql.execution.datasources.jdbc.JDBCRDD$.resolveTable(JDBCRDD.scala:63)
at org.apache.spark.sql.execution.datasources.jdbc.JDBCRelation$.getSchema(JDBCRelation.scala:210)
at org.apache.spark.sql.execution.datasources.jdbc.JdbcRelationProvider.createRelation(JdbcRelationProvider.scala:35)
at org.apache.spark.sql.execution.datasources.DataSource.resolveRelation(DataSource.scala:318)
at org.apache.spark.sql.DataFrameReader.loadV1Source(DataFrameReader.scala:223)
at org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:211)
at org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:167)
... 49 elided
解决方案
推荐阅读
- java - 在 Cucumber 胶水选项包中使用多个类
- python - txt 中的分割线。然后附加到两个列表。使列表翻倍
- angular - 当从 Angular 文档下载项目并运行 ng serve -o 项目定义时找不到
- pandas - 将带有日期列的 pyspark DataFrame 转换为 Pandas 会导致 AttributeError
- python - 如何在 Python 中同时录制音频和视频?
- laravel - gcloud app SQLSTATE[HY000] [2002] 连接超时
- html - 网站上有很多视频
- python-3.x - 所有测试用例都通过了,除了一个抛出关键错误的测试用例
- sql - 消息 8156,级别 16,状态 1,第 17 行 为“t”多次指定了“BID_Close”列
- java - 如何在 Java 中动态更改对象的泛型类型?