(no subject)

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

(no subject)

Ben Yan
The following is the environment I use:
1. flink.version: 1.9.0
2. java version "1.8.0_212"
3. scala version: 2.11.12

When I wrote the following code in the scala programming language, I found the following error:

// set up the batch execution environment
val bbSettings = EnvironmentSettings.newInstance().useBlinkPlanner().inBatchMode().build()
val bbTableEnv = TableEnvironment.create(bbSettings)
error: Static methods in interface require -target:jvm-1.8
[ERROR] val bbTableEnv = TableEnvironment.create(bbSettings)
But when I use the java programming language or the version of scala in 2.12, there is no problem.
If I use the version of scala2.11, is there any way to solve this problem? thanks

Best,
Ben
Reply | Threaded
Open this post in threaded view
|

Re:

Fabian Hueske-2
Hi,

This is clearly a Scala version issue.
You need to make sure that all Flink dependencies have the same version and are compiled for Scala 2.11.
The "_2.11" postfix in the dependency name indicates that it is a Scala 2.11 dependency ("_2.12 indicates Scala 2.12 compatibility).

Best, Fabian

Am Mi., 11. Sept. 2019 um 05:53 Uhr schrieb Ben Yan <[hidden email]>:
The following is the environment I use:
1. flink.version: 1.9.0
2. java version "1.8.0_212"
3. scala version: 2.11.12

When I wrote the following code in the scala programming language, I found the following error:

// set up the batch execution environment
val bbSettings = EnvironmentSettings.newInstance().useBlinkPlanner().inBatchMode().build()
val bbTableEnv = TableEnvironment.create(bbSettings)
error: Static methods in interface require -target:jvm-1.8
[ERROR] val bbTableEnv = TableEnvironment.create(bbSettings)
But when I use the java programming language or the version of scala in 2.12, there is no problem.
If I use the version of scala2.11, is there any way to solve this problem? thanks

Best,
Ben