-
Notifications
You must be signed in to change notification settings - Fork 4.2k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
[BEAM-2377] Allow usage of scala 2.11 dependencies as well as cross compilation for flink runner #3255
Conversation
Build finished. |
scala-2.11 build fails in sdks/java/io/hadoop/jdk1.8-tests due to dependency issue. Investigating. |
Flink allows being built against scala 2.11. But the Flink Runner did not. This commit alleviates that, as well as allowing for ensuring that builds work against scala 2.11 dependencies. It introduces a flink.scala.version mvn property that is set to 2.10 as a default, as well as a mvn profile that overrides the scala version to 2.11.
Cleaned up the pull request, there were unexplainable dependency problems with enabling cross compilation for spark/scala-2.11, so I removed that. My itch is scratched with support for flink-runner/scala-2.11. |
Build finished. |
@davorbonaci I commented on https://issues.apache.org/jira/browse/BEAM-2377. I'm wondering how we should integrate this with the snapshot release process and the actual release process. |
@davorbonaci What do you think we should do for integrating different Scala versions into the release process? Create a new nightly snapshot Jenkins job that also deploys Scala 2.11 builds? And for actual releases we probably have to update the release instructions or do you think it's possible to automate this? |
If Flink users choose a Scala version first and then a corresponding Flink version, I would very much like to support the Beam FlinkRunner working simply for these users. How is this done for Flink? |
With Flink you have to use the right dependencies for your Scala version, i.e. with Scala 2.10 you would have |
What I see as an open question is how releases would work. We use |
@neurolabs I'd like to finally merge this, however, I switched the roles of 2.10 and 2.11 in my local branch and I'd like it to merge like this. I amended your commit. Would that be ok for you? |
Sure, go ahead. |
@neurolabs Thanks for working on this! 😃 |
(And thanks @aljoscha for helping and pushing it across the finish line, despite the lack of response/action from me -- much appreciated.) |
Jenkins presubmit runs are failing with the following error:
https://builds.apache.org/job/beam_PreCommit_Java_MavenInstall/14503/console I would like to propose reverting this change to unblock presubmits and development at head. |
Flink allows being built against scala 2.11. But the Flink Runner did
not.
This commit alleviates that, as well as allowing for ensuring that
builds work against scala 2.11 dependencies for flink. It introduces a
flink.scala.version mvn property that is set to 2.10 as a default, as well as
a mvn profile that overrides the flink scala version to 2.11.
It would be nice if you could cross publish the flink runner for
scala-2.11 based on this pull request.