我正在尝试在 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 网页中没有太多相关信息。