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-pluginscala-compile-first process-resources compile -Xfatal-warnings -Xms128m -Xmx512m ${scala.vaersion} -target:jvm-1.8
执行命令:mvn clean scala:compile scala:run package
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)