[
https://issues.apache.org/jira/browse/BEAM-7544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Cyrille Chépélov updated BEAM-7544:
-----------------------------------
Issue Type: Improvement (was: Bug)
Summary: [workaround available] Please provide a build against scala
2.12 (was: Please provide a build against scala 2.12)
Found a workaround:
In an app that
* uses scio-0.7.4 (last available for now)
** which uses BEAM 2.11.0 (not evictable, scio enforces the version at runtime)
*** which uses Flink-clients 1.5.6 (whereas version 1.7.2 & 1.8.0 are
available for scala-2.12)
it is possible to run the job code under Scala-2.12 by replacing the
BEAM-runner-flink dependency from
```sbt
libraryDependencies +=
"org.apache.beam" %% "beam-runners-flink" % beamVersion
```
to
```sbt
val flinkVersion = "1.7.2" // 1.8.0 drops o.a.f.a.c.t.CompatibilityResult
which beam uses
// beam 2.11.0 depends on "flink-*" % "1.5.6" but only 1.7.0 onwards have a
scala 2.12 build
libraryDependencies ++= Seq(
"org.apache.beam" % "beam-runners-flink_2.11" % beamVersion
// normally the previous line (with %% and sans _2.11) is enough,
but b-r-f is not published in scala 2.12
exclude("org.apache.flink", "flink-clients_2.11")
// flink-core is in Java, does not depend on the scalac ABI
// flink-metrics-core is in Java, does not depend on the scalac ABI
// flink-java is in Java, does not depend on the scalac ABI
exclude("org.apache.flink", "flink-runtime_2.11")
exclude("org.apache.flink", "flink-streaming-java_2.11"),
"org.apache.flink" %% "flink-clients" % flinkVersion,
"org.apache.flink" %% "flink-runtime" % flinkVersion,
"org.apache.flink" %% "flink-streaming-java" % flinkVersion
)
```
This snippet enables runnning a scio job with `--runner=FlinkRunner` under both
scala-2.11 and scala-2.12
> [workaround available] Please provide a build against scala 2.12
> ----------------------------------------------------------------
>
> Key: BEAM-7544
> URL: https://issues.apache.org/jira/browse/BEAM-7544
> Project: Beam
> Issue Type: Improvement
> Components: runner-flink
> Affects Versions: 2.13.0
> Reporter: Cyrille Chépélov
> Priority: Minor
>
> Flink supports scala 2.12 since version 1.7, while BEAM uses Flink 1.8.
> It would be useful to begin supporting scala 2.12 as a preparation towards
> scala 2.13 as well as soon as Flink supports it
>
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
