pyflink per job提交命令

在 PyFlink 中，可以使用以下命令提交作业：

flink run -m <jobmanager_host>:<jobmanager_port> -p <parallelism> <path_to_py_file> <arguments>

其中，参数的含义如下：

- `-m`: 指定 JobManager 的地址和端口号，例如 `localhost:8081`。
- `-p`: 指定作业的并行度。
- `<path_to_py_file>`: 指定 PyFlink 作业的主程序文件路径。
- `<arguments>`: 可选参数，用于传递给作业的参数。

例如，提交一个名为 `word_count.py` 的 PyFlink 作业，并指定并行度为 2：

flink run -m localhost:8081 -p 2 word_count.py

注意，提交作业之前需要确保 PyFlink 和 Flink 的运行环境已经配置好，并且作业的依赖包已经安装。