11 Star 54 Fork 16

Sisyphus / flink-batch-stream

加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
该仓库未声明开源许可证文件(LICENSE),使用请关注具体项目描述及其代码上游依赖。
克隆/下载
Flink作业提交.md 871 Bytes
一键复制 编辑 原始数据 按行查看 历史
Sisyphus 提交于 2020-10-26 09:48 . flink

Flink作业提交

Standalone

模板

flink run [option] <jar-file> <arguments>

参数

-p,--parallelism <parallelism> : job需要指定env的并行度,这个一般都需要设置

-c,--class <classname> : 需要指定的main方法的类

-C,--classpath <url> : 向每个用户代码添加url,他是通过UrlClassLoader加载。url需要指定文件的schema如(file://)

-d,--detached : 在后台运行

-q,--sysoutLogging : 禁止logging输出作为标准输出

-s,--fromSavepoint <savepointPath> : 基于savepoint保存下来的路径,进行恢复

-sas,--shutdownOnAttachedExit : 如果是前台的方式提交,当客户端中断,集群执行的job任务也会shutdown

例子

/opt/flink/bin/flink run -p 1 -c com.test.TestLocal ./flink-streaming-report-forms-1.0-SNAPSHOT-jar-with-dependencies.jar
Scala
1
https://gitee.com/sweetdream/flink-batch-stream.git
git@gitee.com:sweetdream/flink-batch-stream.git
sweetdream
flink-batch-stream
flink-batch-stream
master

搜索帮助