idea快捷键

https://blog.csdn.net/weixin_34168700/article/details/91803102

1. 选择实现方法（select methods to implement）

  1. Ctrl+I

版本选择

maven中查看对应版本：https://blog.csdn.net/DDKii/article/details/105103079

  • flink 为1.11.2
  • Scala为2.11
  • kafka 为2.11
  1. 下载Scala插件

image.png

  1. 新建maven项目

image.png

第一次创建如果没有3选项，点击Add Archetype

image.png

  1. 接下来跟创建maven项目一样，填写项目相关信息

image.png

  1. 创建完之后的项目结构

image.png

  1. 在BatchJob.scala中编写WordCount测试代码 ```scala package org.example

import org.apache.flink.api.scala._

object BatchJob {

def main(args: Array[String]) { // set up the batch execution environment val env = ExecutionEnvironment.getExecutionEnvironment val dataSet = env.readTextFile(“D:\IDEA\flink\src\main\resources\wordcount.txt”) dataSet.flatMap { .toLowerCase.split(“,”)} .filter (.nonEmpty) .map { (_, 1) } .groupBy(0) .sum(1) .print() } } ```

  1. 点击运行后，如果报错：

image.png

解决办法：勾选
image.png
image.png

  1. 点击运行后，出现结果

image.png

  1. 如果不想打印info日志信息，只打印error信息，在log4j2.properties中将INFO改为ERROR

image.png

可以发现只打印出结果
image.png