flink ui 界面怎么提交任务呢??

1357问.png

展开
收起
游客3oewgrzrf6o5c 2022-07-12 16:02:00 719 分享 版权
1 条回答
写回答
取消 提交回答
  • 全栈JAVA领域创作者

    您好,您可以通过 Flink 的 UI 界面来提交一个 Job。具体实现方式如下:

    首先,您需要启动 Flink 的 UI 服务。例如,您可以使用以下命令启动 Flink 的 UI 服务:

    $ ./bin/flink run -c org.apache.flink.client.cli.CliFrontend ./flink-dist/bin/flink run -m yarn-cluster -yn 2 -ys 2 -yjm 1024 -ytm 1024 -c com.example.DemoJob /path/to/jar/file.jar
    

    在这个命令中,我们使用“-m yarn-cluster”参数指定使用 YARN 作为分布式运行时环境,并使用“-yn”和“-ys”参数指定集群中的 YARN NodeManager 数量。然后,我们使用“-yjm”和“-ytm”参数指定每个 NodeManager 上分配的 Java 虚拟机内存和堆内存大小。

    然后,您可以通过浏览器访问 Flink 的 UI 界面。例如,您可以使用以下 URL 访问 Flink 的 UI 界面:

    http://localhost:8080
    

    在 Flink 的 UI 界面中,您可以找到一个名为“Submit Job”的按钮。点击该按钮,即可打开一个表单,您可以在该表单中输入 Job 的相关信息,例如 JobName、ClassPath、JAR 文件等。
    在填写完表单后,点击“Submit”按钮即可提交 Job。您可以在 Flink 的 UI 界面中查看 Job 的运行状态。
    希望这个回复能够帮助您解决问题。

    2023-08-18 07:50:09
    赞同 展开评论

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

收录在圈子:
实时计算 Flink 版(Alibaba Cloud Realtime Compute for Apache Flink,Powered by Ververica)是阿里云基于 Apache Flink 构建的企业级、高性能实时大数据处理系统,由 Apache Flink 创始团队官方出品,拥有全球统一商业化品牌,完全兼容开源 Flink API,提供丰富的企业级增值功能。
还有其他疑问?
咨询AI助理