创建 JAR 作业

最近更新时间:2021-06-25 11:42:47

前提条件

  1. 已创建腾讯云账号,创建账号可参考 注册腾讯云
  2. 若使用子账号登录,需要获得用户帐户的访问授权,详情请参见 CAM 访问管理流计算服务委托授权
  3. 流计算作业 JAR 作业需运行于流计算独享集群,若还没有集群,请参考 创建独享集群

步骤1:JAR 包开发

创建 JAR 作业需要上传已开发好的 JAR 包,您可以单击 GitHub 链接,下载我们提供的 WordCount 示例 JAR 包(文件名为 flink-hello-world-1.0.0.jar)来完成。

步骤2:上传 JAR 包

登录 流计算 Oceanus 控制台,选择【程序包管理】>【新建程序包】。在新建程序包中选择地域,该地域需与独享集群所在地域一致,默认使用本地上传的方式。单击【选择程序包】将打开本地文件选择窗口,选择步骤1中下载的 JAR 包并上传。填写程序包名称、程序包描述、版本说明后,单击【确定】完成新建程序包。完成新建后程序包列表将出现刚新建的程序包。

步骤3:创建 JAR 作业

登录 流计算 Oceanus 控制台,单击左侧导航【作业管理】,进入作业管理页面,单击【新建作业】,作业类型选中 JAR 作业,输入作业名称,并选择一个运行中的集群,新建的 JAR 作业将运行于此集群,单击【确定】后即成功创建作业。

步骤4:流计算服务委托授权

选择【作业管理】中刚新建的作业,单击【开发调试】。在未授权时,弹出访问授权对话框如下,单击【前往授权】,授权流计算作业访问您的 CKafka、TencentDB 等资源。此授权的详细说明参见 流计算服务委托授权

步骤5:配置 JAR 作业

在【开发调试】中,在【主程序包】的下拉框中选择刚才新建的程序包名称,在【主类】输入 com.tencent.cloud.oceanus.wordcount.WordCount。还可在【作业参数】设置中可以调整作业的算子默认并行度。

步骤6:发布运行 JAR 作业

单击【发布运行】,将进行作业运行检查,检查通过后将进入发布确认。发布将生成新的作业版本,版本号由系统自动生成,需输入版本说明并选择运行策略,再单击【确认启动】。

步骤7:查看作业运行情况

作业发布并启动运行后,将变为操作中的状态,成功启动后将变为运行中的状态。作业运行中时,可以通过【监控】、【日志】、【Flink UI】等功能查看作业运行的情况。

目录