小编Kev*_*mez的帖子

如何处理 Spark SQL 上的 AnalysisException?

我正在尝试在 Spark 中执行查询列表,但如果查询未正确运行,Spark 会向我抛出以下错误: AnalysisException: “ALTER TABLE CHANGE COLUMN is not supported for changes ...

这是我的代码的一部分(我在 Databricks 上使用 python 和 Spark SQL):

for index, row in df_tables.iterrows():
  query = row["query"]
  print ("Executing query: ")
  try:
      spark.sql(query)
      print ("Query executed")
  except (ValueError, RuntimeError, TypeError, NameError):
      print("Unable to process your query dude!!")
  else:
      #do another thing
Run Code Online (Sandbox Code Playgroud)

有什么办法可以捕获该异常吗?ValueError、RuntimeError、TypeError、NameError 似乎不起作用。Spark 网页中没有太多相关信息。

python apache-spark apache-spark-sql pyspark databricks

10
推荐指数
3
解决办法
5749
查看次数