本文为您介绍EasyStream实时开发中SQL任务调试的限制和操作步骤。

使用限制

• 任务类型限制：仅有SQL任务可进行调试操作。

操作步骤

1. 新建SQL任务

1. 登录 EasyStream实时计算平台 。
2. 快捷导航栏 选择 实时开发 ，若 快捷导航栏 中无相关选项可参考 快速导航栏 进行操作。
3. 切换至目标 工作空间 。
4. 单击 新建SQL任务 ，在弹出窗口中填写任务配置信息。
5. 单击 确定。

2. 编写FlinkSQL代码

CREATE TABLE datagen (
  `id`   VARCHAR,
  `name` VARCHAR
) WITH (
  'connector' = 'datagen',
  'rows-per-second' = '5'
);

CREATE TABLE blackhole (
  `id` VARCHAR,
  `name` VARCHAR
) WITH (
  'connector' = 'blackhole'
);

CREATE TABLE blackhole_cnt(
  `cnt` BIGINT
) WITH (
  'connector' = 'blackhole'
);

insert into blackhole
  select *
    from datagen;

insert into `blackhole_cnt`
  select count(*)
    from datagen;

3. 从数据采样

上方代码案例中使用的为'datagen'数据源直接仿造数据，若数据来源为Kafka等，可以参考此步骤进行数据样本的采集、编辑、保存。

1. 在SQL任务中添加source块，选择数据源类型、数据库、表，并可在配置中设置set参数。
   

2. 单击 调试 按钮，下方出现 调试 日志和结果。在结果页面双击任意值，可对值进行编辑；单击保存，采样结果将被保存为正式样本，并可用于后续代码调试。
   

3. 在调试过程中单击 停止调试 按钮即可强制取消调试。

4. SQL调试

1. 单击 SQL 块的 调试 按钮，在调试样本选择侧边栏中为每个源端表选择调试数据后单击确定。
   
2. 调试结果将展示在SQL下方，不会真实写入目标表。任务调试后可将调试结果保存为公共样本。保存时样本名称按照[任务名称]_[目标表名称]自动生成，重复保存时同名样本将被更新。