1 使用Flink的自带的mvn命令构建构架
mvn archetype:generate \
-DarchetypeGroupId=org.apache.flink \
-DarchetypeArtifactId=flink-quickstart-scala \
-DarchetypeVersion=1.6.1
-
将项目导入到IDEA中，如果在项目中用到hadoop的环境：
-
注意算子在scala中使用，需要导包 import org.apache.flink.streaming.api.scala._
