您可以使用作业调试功能模拟作业运行、检查输出结果,验证SELECT业务逻辑的正确性,提升开发效率,降低数据质量风险。

前提条件

已创建用于SQL Preview的Session集群,因为系统在作业调试前会检测是否有可用的Session集群,如果无Session集群时,则会提示并引导您配置用于SQL Preview的Session集群。配置Session集群详情请参见配置Session集群

操作步骤

  1. 登录实时计算统一控制台
  2. Flink全托管页签,单击目标工作空间操作列下的开发控制台
  3. 分别注册源表和结果表。您可以通过以下任何一种方式进行。
    • 直接编写完整的建表语句
      1. 在左侧导航栏,单击SQL编辑器
      2. 单击新建文本
      3. 输入源表或结果表DDL语句。
      4. 单击验证
      5. 单击运行

        注册成功的表会出现在SQL编辑器左侧的Tables列表中,您可以单击表名,查看表的字段和数据类型信息。

    • 根据目标Connector语句模板修改定义
      1. 在左侧导航栏上,单击SQL编辑器
      2. 单击Schemas页签。
      3. 单击Tables旁边的创建表图标。
      4. 单击目标Connector。
        相关建表语句就会出现在SQL编辑器中。建表语句
      5. 在文本编辑框中,修改Schema和WITH参数。
        说明 如果您的SQL需要使用UDF,您需要先注册您的UDF,才能在SQL中使用,注册UDF的操作请参见管理自定义函数(UDF)
      6. 单击验证
      7. 单击运行

        注册成功的表会出现在SQL编辑器左侧的Schemas页签中的Tables列表中,您可以单击表名,查看表的字段和数据类型信息。

  4. Scripts页签,单击新建文本
  5. 编写调试SQL语句。
    简单的逻辑示例如下。
    SELECT XXX FROM 源表;
    注意 CDC源表暂不支持SQL Preview功能,因为它不是Append-only模式的。
  6. 单击验证
    在SQL编辑页面下方,您可以看到SQL语法校验结果,只有通过校验的SQL才能被运行。
  7. 单击运行
    单击运行后,会在SQL编辑器下方显示调试结果。调试结果
    说明 Flink全托管默认读取最多1000条数据后会自动停止。