本文为您介绍如何新建实时计算任务,并通过Stream Studio进行数据开发。
前提条件
DAG模式开发
转换DAG模式与SQL模式
配置好DAG业务流程后,单击右上方的切换为SQL模式,即可转换DAG模式为SQL模式。

该功能可以转换DAG业务流程为Flink SQL。在SQL模式中,也可以单击切换为DAG模式,转换SQL模式为DAG模式。
您可以直接在SQL模式中进行SQL任务开发。由于Flink SQL的功能比DAG更为强大,因此可能部分SQL语句无法转成DAG。随着组件的增加和完善,未来将支持Flink SQL所有特性都能够转换为DAG业务流程。
预编译与测试运行
编辑好DAG或SQL后,可以在工具条中单击预编译,对任务进行预编译,以便提前检查错误。如果有错误,则会弹出错误信息,您可以根据错误信息对任务进行修改。

预编译通过后,可以进行测试运行,即本地调试。测试运行允许您上传样本数据对流计算任务进行本地测试。
单击工具条中的测试运行按钮。在弹出的对话框中,针对任务中的每个数据源表及数据维表都上传一份样本数据,然后单击确认,进行任务的本地测试。

如果运行成功,则会在下方显示运行结果。如果运行失败,请查看运行日志对任务进行修改。
发布任务
任务编辑完成且测试运行通过后,即可正式发布任务。
单击工具条右侧的发布,即可一键发布任务。
任务发布后,单击页面右上角的运维,进入运维页面,对任务进行启动、暂停、恢复和下线等操作,详情请参见周期任务。
在文档使用中是否遇到以下问题
更多建议
匿名提交