[
https://issues.apache.org/jira/browse/BEAM-7544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16911097#comment-16911097
]
wilber chao commented on BEAM-7544:
-----------------------------------
About the work around of [~cchepelov] mentioned:
{code:java}
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 buildlibraryDependencies ++= 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
)
{code}
I found that `"org.apache.beam" % "beam-runners-flink_2.11" % beamVersion`
depends on Flink 1.5, and the included Flink is 1.7.2
Above would have problem of
[java.lang.IncompatibleClassChangeError|[https://stackoverflow.com/questions/52713906/when-using-kafkabeamflink-found-interface-org-apache-flink-streaming-api-oper/57569030#57569030]]
Depending on "org.apache.beam" % "beam-runners-flink-1.7" % beamVersion is
better with Flink is 1.7.2
> [workaround available] Please provide a build against scala 2.12 for Flink
> runner
> ---------------------------------------------------------------------------------
>
> Key: BEAM-7544
> URL: https://issues.apache.org/jira/browse/BEAM-7544
> Project: Beam
> Issue Type: Improvement
> Components: runner-flink
> Affects Versions: 2.11.0, 2.13.0
> Environment: scio 0.7.4 + scala 2.12.8
> Reporter: Cyrille Chépélov
> Priority: Minor
> Fix For: Not applicable
>
>
> 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
(v8.3.2#803003)
