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

在Flink中,可以通过命令行提交、展示和取消作业。以下是如何使用命令行操作Flink作业的示例:

  1. 提交作业
./flink run -c com.example.MainClass /path/to/your/job.jar [jobArgs]

这里,run是提交作业的命令,-c后面跟着的是主类的全路径,接着是jar文件的路径和可选的作业参数。

  1. 展示作业
./flink list

这将列出当前Flink集群中所有运行的作业。

  1. 取消作业
./flink cancel JOB_ID

以上命令假设你在Flink的命令行工具目录下执行,并且你有正确的权限和配置。如果你的Flink集群部署在远程服务器上,你可能需要通过SSH或其他方式连接到远程服务器,然后执行上述命令。

命令行

  1. 启动本地 Flink 集群:
./bin/start-cluster.sh
  1. 停止本地 Flink 集群:
./bin/stop-cluster.sh
  1. 提交一个作业到 Flink 集群运行:
./bin/flink run examples/streaming/WordCount.jar
  1. 停止正在运行的作业:
./bin/flink cancel <job-id>
  1. 列出所有运行的作业:
./bin/flink list
  1. 列出作业的详细信息:
./bin/flink info <job-id>

7/ 列出savepoint能够恢复的作业:

./bin/flink savepoint <job-id> [savepointDirectory]
  1. 从savepoint恢复作业:
./bin/flink run -s :savepointMetaDataPath <program> [<arguments>]
  1. 更新运行中的作业的并行度:
./bin/flink update <job-id> -p <newParallelism>
  1. 从指定的jar或者类运行一个新的程序:
./bin/flink run -c <main-class> <jar-file> <arguments>

注意: 这些命令应在 Flink 安装目录的命令行终端中执行。每个命令的具体参数和用法可以通过在命令后添加 --help 来查看详细的帮助信息,例如:./bin/flink run --help。

相关推荐

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

    2024-06-13 15:48:03       25 阅读
  2. Flink 命令提交展示取消作业

    2024-06-13 15:48:03       31 阅读
  3. Flink命令提交时参数的传递

    2024-06-13 15:48:03       42 阅读
  4. git命令提交——github

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

    2024-06-13 15:48:03       34 阅读
  6. Flink命令启动Job任务

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

    2024-06-13 15:48:03       56 阅读

最近更新

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

    2024-06-13 15:48:03       94 阅读
  2. Could not load dynamic library ‘cudart64_100.dll‘

    2024-06-13 15:48:03       101 阅读
  3. 在Django里面运行非项目文件

    2024-06-13 15:48:03       82 阅读
  4. Python语言-面向对象

    2024-06-13 15:48:03       91 阅读

热门阅读

  1. 深入浅出: XML HttpRequest 入门指南

    2024-06-13 15:48:03       35 阅读
  2. Release和Debug的区别?Release有什么好处?【面试】

    2024-06-13 15:48:03       27 阅读
  3. QT与VS的区别?使用QT的好处?

    2024-06-13 15:48:03       29 阅读
  4. P3842 [TJOI2007] 线段

    2024-06-13 15:48:03       35 阅读
  5. 大数据平台之权限管理

    2024-06-13 15:48:03       31 阅读
  6. 【代码】数据类型之基本数据类型

    2024-06-13 15:48:03       28 阅读
  7. 软件版本库管理工具

    2024-06-13 15:48:03       34 阅读
  8. odoo15 与odoo16的一个小更新add_sign

    2024-06-13 15:48:03       32 阅读
  9. 重温react-03

    2024-06-13 15:48:03       26 阅读