flink run 启动参数

flink run 启动参数 通用: -c,–class 使用程序入口点("main()"方法)初始化。仅当JAR文件没有在其清单中指定类时才需要。 -C,–classpath 向集群中所有节点上的每个用户代码类加载器添加URL。这些路径必须指定一个协议(例如file://)，并且在所有节点上都可以访问(例如通过NFS共享)。您可以多次使用此选项来指定多个URL。该协议必须由{@link java.net.URLClassLoader}支持。 -d,–detached 如果存在，则以分离模式运行作业 -n,–allowNonRestoredState 允许跳过无法恢复的保存点状态。如果您从程序中删除了一个 *** 作符，该 *** 作符在触发保存点时是程序的一部分，则需要允许这样做。 -p,–parallelism 运行程序的并行度。可选标志，覆盖配置中指定的默认值。 -s,–fromSavepoint 恢复任务的保存点路径(例如hdfs:///flink/savepoint-1537)。 -sae,–shutdownOnAttachedExit 如果作业是以附加模式提交的，则在CLI突然终止时(例如，响应用户中断，如输入Ctrl + C)执行最大努力的集群关闭。 通用的CLI -D 允许指定多个通

欢迎分享，转载请注明来源：内存溢出

原文地址: http://outofmemory.cn/zaji/4684347.html