How to specify which columns to use when using DLT APPLY CHANGES INTO

Magnus — Wed, 09 Nov 2022 14:53:15 GMT

I have a notebook with the code below, where I try to do an upsert into a dimension table and only include one column from the source table. I get an error even though I think the syntax matches what I see in the docs. How can I write this in the correct way?

CREATE OR REFRESH LIVE TABLE D_AzureResourceType_DLT
(
  WkAzureResourceType bigint GENERATED ALWAYS AS IDENTITY,
  ConsumedService string NOT NULL
);
 
APPLY CHANGES INTO
  LIVE.D_AzureResourceType_DLT
FROM
  STREAM(LIVE.AzureCost)
KEYS
  (ConsumedService)
SEQUENCE BY
  Date
COLUMNS (ConsumedService);

Currently, the "Initializing" step in the Delta Live Tables workflow fails with this error:

topic How to specify which columns to use when using DLT APPLY CHANGES INTO in Data Engineering

How to specify which columns to use when using DLT APPLY CHANGES INTO