1.通过命令快速生成一个flink项目

curl https://flink.apache.org/q/quickstart.sh | bash -s 1.19.1

生成文件目录：

其中pom文件包好我们所需要的基础flink相关依赖

2.测试

public class DataStreamJob {

	public static void main(String[] args) throws Exception {
		final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
		DataStreamSource<String> stringDataStreamSource = env.fromData(Arrays.asList("1", "2", "3"));
		stringDataStreamSource.print();
		env.execute("Flink Java API Skeleton");
	}
}

3.测试结果

成功！