java 启动flink指令
时间: 2023-11-10 22:00:50 浏览: 196
java实现flink订阅Kerberos认证的Kafka消息示例源码
Java启动Flink的指令可以使用以下命令:
```
./bin/flink run -m yarn-cluster -yn 2 -yjm 1024 -ytm 1024 -c com.example.YourMainClass /path/to/your/application.jar
```
其中,`-m yarn-cluster`表示以Yarn集群模式启动;`-yn 2`表示使用2个Yarn容器;`-yjm 1024`表示指定每个Yarn容器的JobManager内存为1024MB;`-ytm 1024`表示指定每个Yarn容器的TaskManager内存为1024MB;`-c com.example.YourMainClass`表示指定Flink应用程序的主类;`/path/to/your/application.jar`表示指定Flink应用程序的jar包路径。
阅读全文