在Flink scala中使用WatermarkStrategy类中的方法maven编译时抛出以下异常
[ERROR] /Users/duzhixin/flink-dw/src/main/scala/come/bigdata/etl/FlinkEvent.scala:26: error: Static methods in interface require -target:jvm-1.8[INFO] val eventStream = env.fromSource(kafkaSource, WatermarkStrategy.noWatermarks[String],"Kafka Source With Custom Watermark Strategy")
解决:maven里加上
如下
完整scala maven build pom.xml如下,net.alchim31.maven 里的scala maven 插件用了会有坑,注释掉了
但是如果要在idea里run,还需要单独设置 scala compiler