一、准备flink的开发环境

1.创建project

2.选择Scala project

3.输入project基本信息

1.填写项目的名称信息
2.填写项目的位置信息

4.project创建成功后的效果

5.配置project's SDK

选择Java的本地安装目录，也就是$JAVA_HOME

6.配置modules的目录属性

1.配置java的source目录，以便进行flink的Java开发
2.配置scala的source目录，以便进行flink的scala开发
3.其他目录，以后用到再进行配置

7.配置libraries

1.选择scala的本地安装目录，也就是$SCALA_HOME
2.选择flink的本地安装目录，也就是$FLINK_HOME

二、开发并运行flink程序

1.创建package

2.输入package名称

3.创建object

注意：为了简单起见，要选择object，不要选择class.不然在代码里面还要改动。

4.输入object名称

5.创建后的默认代码

6.编写程序

package code.helloword

//0.引入必要的程序元素
import org.apache.flink.api.scala._

object HelloFlink {
  def main(args: Array[String]): Unit = {
    // 1.设置运行环境
    val env = ExecutionEnvironment.getExecutionEnvironment

    //2.创造测试数据
    val text = env.fromElements(
      "To be, or not to be,--that is the question:--",
      "Whether 'tis nobler in the mind to suffer",
      "The slings and arrows of outrageous fortune",
      "Or to take arms against a sea of troubles,")

    //3.进行wordcount运算
    val counts = text.flatMap(_.toLowerCase.split("\\W+"))
      .map((_, 1)).groupBy(0).sum(1)
    //4.打印测试结构
    counts.print()
  }
}

7.运行程序

8.运行效果

三、打包到服务器上运行

1.配置artfact

2.选择程序入口class

3.删除不必要的libraries

4.配置好的效果

5.build artfact

6.选择build或rebuild

7.选择build成果物展示

8.上传到服务器，并运行jar

${FLINK_HOME}/bin/flink run  -m qingcheng11:6123  simple-flink.jar

9.terminal中的执行效果

10.flink-web-UI中的执行效果