search

findify / flink-adt

Scala ADT support for Apache Flink
MIT License
51 stars 9 forks source link

Consider replacing Flink Scala dependencies with Java equivalents #13

Closed NickBurkard closed 2 years ago

NickBurkard commented 2 years ago

Flink 1.15 will enable users to load their own Scala versions, rather than forcing 2.11 or 2.12 at the cluster level. This opens up the opportunity for developers to use Scala 2.13 and even Scala 3.

As a first step, flink-scala and flink-streaming-scala libraries would need to be replaced with their Java equivalents. This will likely require porting over some Scala-specific classes, such as common serializers for Option / Either / etc..

I am currently working on trying this out on my own local fork, if there's interest in supporting newer versions of Scala I can submit a PR once it's done.

NickBurkard commented 2 years ago

I got a fork cross-compiling to Scala 2.13: https://github.com/NickBurkard/flink-adt

shuttie commented 2 years ago

I'm also considering doing it, but prefer to wait for an official 1.15 release

shuttie commented 2 years ago

As 1.15 is released this week, flink-adt is now available both for 2.12 and 2.13 scala versions.