我在databricks notebook中运行了一个非常简单的查询,其中包含一个子查询。record_date >= date_sub(current_date(), 1) group by recorddate
order by recorddate 我得到以下异常:错误在SQL语句: package.TreeNodeException:绑定属性,树:记录日期 当删除order by子句时,查询运行正常。
下面一行在databricks中工作,但在scala代码中抛出了一个错误:
val spark(rows: java.util.List[org.apache.spark.sql.Row],schema: org.apache.spark.sql.types.StructType)org.apache.spark.s
spark.sql.extensions com.datastax.spark.connector.CassandraSparkExtensionsspark.conf.get当在Cassandra集群上直接运行相同的CQL查询时,它会产生一个结果。 at org.apache.spark.sql.ca
<init>(Parameters.scala:91)at com.databricks.spark.redshift.DefaultSource.createRelation(DefaultSource.scala:50)
at org.apache.spark.sql.execution.datasource
当我在Databricks/PySpark中运行查询时,我得到以下错误:
org.apache.spark.SparkException: Could not execute broadcast inYou can increase the timeout for broadcasts via spark.sql.broadcastTimeout or disable broadcast joinby setting spark.sql.autoBroadca