使用场景一:创建弹性资源池并运行作业 运行作业 本示例通过在弹性资源池队列上运行一个Flink SQL举例演示。 1. 在DLI管理控制台,单击“作业管理 > Flink作业”,在Flink作业管理界面,单击“创建作业”。 2. 在创建作业界面,类型选择“Flink SQL”,名称填写为:testFlinkSqlJob。单击“确定”,跳转到Flink作业编辑界面。 3. 在Flink SQL作业编辑界面,配置如下参数。 −所属队列:选择步骤二:添加队列到弹性资源池中弹性资源池添加的队列“generaltest”。 −保存作业日志:勾选。 −OBS桶:选择保存作业日志的OBS桶,根据提示进行OBS桶权限授权。 −开启Checkpoint:勾选。 −Flink作业编辑框中输入具体的作业SQL,本示例作业参考如下。具体加粗的参数需要根据实际情况修改。 CREATE SINK STREAM carinfo (id INT, name STRING) WITH ( type "rds", region "", / 根据情况修改为当前的region ID/ 'pwdauthname'"xxxxx", // DLI侧创建的Password类型的跨源认证名称。使用跨源认证则无需在作业中配置账号和密码。 dburl "mysql://192.168.x.x:3306/test2", / 格式为mysql://RDS数据库实例的内网地址:RDS数据库端口/RDS创建的数据库名 / tablename "tabletest2" / RDS数据下的表名 / ); INSERT INTO carinfo SELECT 13, 'abc'; 4.单击“语义校验”确保SQL语义校验成功。单击“保存”,保存作业。单击“启动”,启动作业,确认作业参数信息,单击“立即启动”开始执行作业。 5.等待作业运行完成,作业状态显示为“已完成”。 6.登录RDS控制台,单击RDS数据库实例,单击创建的数据库名,如“test2”,在创建的表“tabletest2”所在行的“操作”列,单击“SQL查询”。 7.在“SQL查询”界面,单击“执行SQL”,查看RDS表数据已写入成功。