Flink有多种提交方式：local，standalone和yarn。本节将分别演示这几种提交方法。

1、 local：

public class TestLocal {
    public static void main(String[] args) throws Exception {
        ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
        env
                .readTextFile(args[0])
                .print();
    }
}

在Program arguments中设置路径，直接在idea中执行，便能看到效果。

2、 standalone：

• 已经在centos完成安装flink
• 在idea中将以上代码打成jar包，假设名称为flink-1.0.jar，确保jar包中的META-INF/MANIFEST.MF中包括Main-Class

Manifest-Version: 1.0
Archiver-Version: Plexus Archiver
Built-By: zhangli
Created-By: Apache Maven 3.3.9
Build-Jdk: 1.8.0_162
Main-Class: TestLocal

• 上传jar包到centos的/root目录
• 执行以下命令，假设/root路径下包括info.txt：

/root/flink-1.2.1/bin/flink run /root/flink-1.0.jar /root/info.txt

以上就是Flink的几种提交方式。