sql - 雪花任务没有给我任何错误，但表是空的

Question

我在雪花中有以下任务：

CREATE OR REPLACE TASK TSK_MASTER
    WAREHOUSE = MYWH
    SCHEDULE = '1 MINUTE'
WHEN
  SYSTEM$STREAM_HAS_DATA('MYSTREAM')
AS
    INSERT INTO USER_DATA(ID,CREATED_AT,DEACTIVATED,EMAIL_ADDRESS,NAME,ROLE)
    SELECT
      vm.VALUE:id::string AS "ID",
      vm.VALUE:created_at::timestamp AS "CREATED_AT",
      vm.VALUE['profile']:deactivated::boolean AS "DEACTIVATED",
      vm.VALUE['profile']:email_address::string AS "EMAIL_ADDRESS",
      vm.VALUE['profile']:name::string AS "NAME",
      vm.VALUE:role::string AS "ROLE"
    FROM
        MYSTREAM
        , lateral flatten(input => RAW_JSON) vm
    WHERE
        vm.VALUE:entity_type::string = 'member'
        AND
        METADATA$ACTION = 'INSERT';

SELECT SYSTEM$STREAM_HAS_DATA('MYSTREAM')是TRUE，但我的任务似乎没有运行。

然后，我对以下问题进行故障排除并按预期获取 ID。

SELECT
      vm.VALUE:id::string AS "ID"
FROM
    MYSTREAM
    , lateral flatten(input => RAW_JSON) vm
WHERE
    vm.VALUE:entity_type::string = 'member'
    AND
    SYSTEM$STREAM_HAS_DATA('MYSTREAM')
    AND
    METADATA$ACTION = 'INSERT';

标签： sqltasksnowflake-cloud-data-platform

Answer 1

你需要做的就是ALTER TASK <TASK_NAME> RESUME