代码拉取完成,页面将自动刷新
模板
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
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。