Databricks Delta Live Tables中APPLY CHANGES INTO执行失败求助

安全阿岳

2026-7-6

Delta Live Tables中APPLY CHANGES INTO执行失败问题解决

问题背景

我是Databricks Delta Live Tables新手，测试场景为将Schema中两张普通表关联后，用APPLY CHANGES INTO语句将关联结果合并到空目标表，但执行失败，错误提示为Update 5a190f is FAILED。

使用的脚本如下：

WITH cte AS (
  SELECT
    distinct a.PK,
    a.Value AS first_name,
    b.VALUE AS last_name
  FROM xx_xxx_xxx_dev.sandbox.tablea AS A
  JOIN xx_xxx_xxx_dev.sandbox.tableb AS B ON a.PK = b.FK
)

APPLY CHANGES INTO xx_xxx_xxx_dev.sandbox.joined_table
FROM cte
KEY (PK);

已尝试的操作：

在Notebook中提前创建目标表未成功
在管道指定的目标Schema中手动创建了目标表
调整过脚本中分号的位置

可能的原因及解决方法

1. 目标表不符合DLT变更应用要求

APPLY CHANGES INTO要求目标表是Delta格式，且无需手动添加CDC元数据列。若手动创建目标表，执行以下标准语句：

CREATE TABLE xx_xxx_xxx_dev.sandbox.joined_table (
  PK STRING, -- 替换为你的PK实际数据类型
  first_name STRING,
  last_name STRING
) USING DELTA;

创建后确保DLT管道的服务主体对该表有INSERT、UPDATE权限。

2. 源数据缺少变更类型，需指定同步模式

默认情况下APPLY CHANGES INTO期望源数据包含变更类型标识（如插入/更新），但你的场景是全量同步到空表，需添加APPLY AS DELETE INSERT模式来适配：

WITH cte AS (
  SELECT
    distinct a.PK,
    a.Value AS first_name,
    b.VALUE AS last_name
  FROM xx_xxx_xxx_dev.sandbox.tablea AS A
  JOIN xx_xxx_xxx_dev.sandbox.tableb AS B ON a.PK = b.FK
)

APPLY CHANGES INTO xx_xxx_xxx_dev.sandbox.joined_table
FROM cte
KEY (PK)
APPLY AS DELETE INSERT;

该模式会先删除目标表中与源匹配的键记录，再插入新数据，适合全量同步场景。