1、match模式匹配，值匹配

注意一定要写 case_
否则报错，从报错信息上看不出解决办法
# [scala.MatchError： value._1 （类java.lang.String）]

 value._1 match {
        case "1" =>
        case "news" =>
        case "wemedia" =>
        case "xtv" =>
        case _  => println(s"Nothing Matched!!,table:${value._1}")
      }

2、flink 序列化异常

image.png

• 使用自定义的类，请实现序列化接口
  本人使用场景RichFlatMapFunction的成员变量中使用

  
  image.png

3、 flink es sink

• flink 1.7.2
• es flink-connector-elasticsearch6_2.12
  java.lang.NoClassDefFoundError: org/apache/http/client/config/RequestConfig

解决办法

• 在maven依赖顶部声明依赖

 <dependency>
            <groupId>org.apache.httpcomponents</groupId>
            <artifactId>httpclient</artifactId>
            <version>4.5.8</version>
</dependency>