必须删除spark.conf.set中..autoMerge.enabled之后的空格
--> It's

spark.conf.set("spark.databricks.delta.schema.autoMerge.enabled","true")

字符串
，不是

spark.conf.set("spark.databricks.delta.schema.autoMerge.enabled ","true")`

型

我也有同样的问题，但我发现在delta lake docs中，它可能不太支持upsertAll（）和insertAll（）的部分列;所以我选择了upsertExpr（）和insertExpr（），其中一个大map包含所有列。
delta lake merge : Schema validation

如果我没有弄错的话，您需要在MERGE操作中使用insertAll或updateAll选项

spark.conf.set（“spark.databricks.delta.schema.autoMerge.enabled”，“true”）
确保在上面一行中的“enabled”之后没有空格。
然后你可以使用pass a spark sql：

spark.sql(f"""
MERGE INTO {data_path} delta USING global_temp.src source
       ON   delta.col1   =    source.key1
       AND  delta.col2   =    source.key2
      
       WHEN MATCHED THEN
         UPDATE SET *
         
       WHEN NOT MATCHED THEN
         INSERT *
""")

字符串

deltaTable.as("target")
.merge(data.as("source"),
  "source.internalUUID = target.internalUUID")
.whenMatched().updateAll()
.whenNotMatched().insertAll()
.execute();

字符串