Flink 命令行提交、展示和取消作业

Apache Flink 是一个流处理和批处理的开源框架,用于在分布式环境中执行无边界和有边界的数据流。你可以使用 Flink 的命令行界面(CLI)来提交、展示和取消作业。

提交作业

使用 Flink CLI 提交作业的命令格式通常如下:

./bin/flink run -m <jobmanager_host>:<jobmanager_port> -c <entrypoint_class> <jar_file_path> <arguments>
  • -m <jobmanager_host>:<jobmanager_port>:指定 JobManager 的地址和端口。
  • -c <entrypoint_class>:指定 JAR 文件中包含作业入口点的类。
  • <jar_file_path>:要提交的 JAR 文件的路径。
  • <arguments>:传递给作业的任何可选参数。

例如:

./bin/flink run -m localhost:6123 -c com.example.MyFlinkJob /path/to/my-flink-job.jar --input /path/to/input --output /path/to/output

展示作业

要查看 Flink 集群上正在运行的作业,你可以使用 Flink 的 Web UI。默认情况下,Web UI 可以在 JobManager 的 8081 端口上访问(例如,http://localhost:8081/)。在 Web UI 上,你可以看到所有正在运行的作业、它们的任务、以及相关的性能指标。

另外,你也可以使用 Flink CLI 的 list 命令来列出正在运行的作业:

./bin/flink list -m <jobmanager_host>:<jobmanager_port>

取消作业

要取消 Flink 集群上正在运行的作业,你可以使用 Flink CLI 的 cancel 命令,并指定作业的 ID:

./bin/flink cancel -m <jobmanager_host>:<jobmanager_port> <job_id>

其中 <job_id> 是你想要取消的作业的 ID。你可以通过 Flink Web UI 或 list 命令来获取作业的 ID。

例如:

./bin/flink cancel -m localhost:6123 00000000000000000000000000000000

注意:你需要确保你有足够的权限来提交、展示和取消作业。在某些环境中,可能需要特定的身份验证或授权。

相关推荐

  1. Flink 命令提交展示取消作业

    2024-06-18 13:40:02       25 阅读
  2. Flink 命令提交展示取消作业

    2024-06-18 13:40:02       32 阅读
  3. Flink命令提交时参数的传递

    2024-06-18 13:40:02       42 阅读
  4. git命令提交——github

    2024-06-18 13:40:02       44 阅读
  5. flink 作业动态维护更新,不重启flink,不提交作业

    2024-06-18 13:40:02       34 阅读
  6. Flink命令启动Job任务

    2024-06-18 13:40:02       36 阅读
  7. uniapp提交带有弹出确认取消按钮方法提交接口

    2024-06-18 13:40:02       56 阅读

最近更新

  1. docker php8.1+nginx base 镜像 dockerfile 配置

    2024-06-18 13:40:02       98 阅读
  2. Could not load dynamic library ‘cudart64_100.dll‘

    2024-06-18 13:40:02       106 阅读
  3. 在Django里面运行非项目文件

    2024-06-18 13:40:02       87 阅读
  4. Python语言-面向对象

    2024-06-18 13:40:02       96 阅读

热门阅读

  1. Git常用命令

    2024-06-18 13:40:02       37 阅读
  2. Trie

    2024-06-18 13:40:02       32 阅读
  3. 怎么把包含其他文件的 Python 脚本等打包成 EXE?

    2024-06-18 13:40:02       39 阅读
  4. 深入了解Postman:接口测试工具详解

    2024-06-18 13:40:02       35 阅读
  5. PostgreSQL查看表的大小

    2024-06-18 13:40:02       31 阅读
  6. ABAP随笔记

    2024-06-18 13:40:02       56 阅读
  7. Android10 动态修改开机动画(三)命令说明

    2024-06-18 13:40:02       25 阅读
  8. PHP框架详解:Symfony框架讲解

    2024-06-18 13:40:02       38 阅读
  9. DDP、FDDP、BOXDDP算法概要

    2024-06-18 13:40:02       38 阅读
  10. JVM-GC-G1垃圾回收器

    2024-06-18 13:40:02       24 阅读
  11. PostgreSQL源码分析 —— FunctionScan

    2024-06-18 13:40:02       22 阅读
  12. mysql集群,两主两从,使用mysql-proxy实现读写分离

    2024-06-18 13:40:02       30 阅读
  13. MySQL WHERE子句的使用和优化方法

    2024-06-18 13:40:02       32 阅读