flink启动命令(flink单机部署)

idea-----File----new---Project------Maven----Create from archetype----Add Archetype

弹出框：

GroupId填org.apache.flink

ArtifactId填flink-quickstart-java

Version填1.14.0

选中刚刚添加的Archetype，点Next

填写你要创建的这个flink demo的GroupId,ArtifactId,Version,点击Next

创建项目，自动导入依赖的jar，pom中主要的jar

pom里面的provided全注释掉

1.14.0

   org.apache.flink
   flink-java
   ${flink.version}


   org.apache.flink
   flink-streaming-java_${scala.binary.version}
   ${flink.version}


   org.apache.flink
   flink-clients_${scala.binary.version}
   ${flink.version}

排查了好多问题，最终来到了这里，排查的重点错误可以看https://www.cnblogs.com/yb38156/p/15545379.html这篇

package org.example;


import org.apache.flink.api.common.functions.FlatMapFunction;
import org.apache.flink.api.java.DataSet;
import org.apache.flink.api.java.ExecutionEnvironment;
import org.apache.flink.api.java.tuple.Tuple2;
import org.apache.flink.util.Collector;

public class WordCount {
    public static void main(String[] args) throws Exception {
        // 创建Flink运行的上下文环境
        final ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
        // 创建DataSet，这里我们的输入是一行一行的文本
        DataSet text = env.fromElements(
                "Flink Spark Storm",
                "Flink Flink Flink",
                "Spark Spark Spark",
                "Storm Storm Storm"
        );
        // 通过Flink内置的转换函数进行计算
        DataSet> counts =
                text.flatMap(new LineSplitter())
                        .groupBy(0)
                        .sum(1);
        //结果打印
        counts.printToErr();
    }

    public static final class LineSplitter implements
            FlatMapFunction> {
        @Override
        public void flatMap(String value, Collector> out) {
            // 将文本分割
            String[] tokens = value.toLowerCase().split("\W+");
            for (String token : tokens) {
                if (token.length() > 0) {
                    out.collect(new Tuple2(token, 1));
                }
            }
        }
    }
}

过时的方法已经全部换成了最新的