flink应用 代码编译是报 Static methods in interface require -target:jvm-1.8
val env: StreamExecutionEnvironment = StreamExecutionEnvironment.getExecutionEnvironment
val brokers: String = KafkaUtils.kafkaServer
val topic: String = KafkaUtilsTests.topicName
val group: String = "flink_test_gruop"
val source: KafkaSource[String] = KafkaSource.builder[String]
.setBootstrapServers(brokers).setGroupId(group)
.setTopics(topic)
.setDeserializer(KafkaRecordDeserializationSchema.valueonly(new SimpleStringSchema()))
.setStartingOffsets(OffsetsInitializer.latest).build
val value: DataStream[String] = env.fromSource(source, WatermarkStrategy.noWatermarks[String], "StateMachineExampleSource")
value.print()
// trigger program execution
env.execute("State machine job")
具体异常：
[INFO] compiling 3 Scala sources and 2 Java sources to F:learntotalflinkworkspaceMY_Flinktargetclasses ...
[ERROR] F:/learntotal/flink/workspace/MY_Flink/src/main/scala/com/hg/bigdata/flink/stream/KafkaStreamTests.scala:23: Static methods in interface require -target:jvm-1.8
[ERROR] F:/learntotal/flink/workspace/MY_Flink/src/main/scala/com/hg/bigdata/flink/stream/KafkaStreamTests.scala:24: Static methods in interface require -target:jvm-1.8
[ERROR] F:/learntotal/flink/workspace/MY_Flink/src/main/scala/com/hg/bigdata/flink/stream/KafkaStreamTests.scala:25: Static methods in interface require -target:jvm-1.8
[ERROR] three errors found
[INFO] ------------------------------------------------------------------------
[INFO] BUILD FAILURE
解决：scala-maven-plugin插件中加入 -target:java-1.8
net.alchim31.maven
scala-maven-plugin
scala-compile-first
process-resources
compile
-Xfatal-warnings
-Xms128m
-Xmx512m
${scala.vaersion}
-target:jvm-1.8
执行命令：mvn clean scala:compile scala:run package
