版本: 1.0

Application 模式提交

做好集群配置

具体配置教程参考集群配置: http://www.dinky.org.cn/docs/next/user_guide/register_center/cluster_manage#%E9%9B%86%E7%BE%A4%E9%85%8D%E7%BD%AE%E5%88%97%E8%A1%A8

创建FlinkSql作业

在数据开发中创建FlinkSql作业

create_flinkSql_job

编写FlinkSql

DROP table if exists datagen;
CREATE TABLE datagen (
  a INT,
  b varchar
) WITH (
  'connector' = 'datagen',
  'rows-per-second' = '1',
  'number-of-rows' = '50'
);
DROP table if exists print_table;
CREATE TABLE print_table (
  a INT,
  b varchar
) WITH (
  'connector'='print'
);


insert into print_table  select a,b from datagen ;