flink-scala-api

flink-scala-api copied to clipboard

Cannot submit jobs to Flink

7

Hey There, I was just trying this out via the Giter template. I followed the instructions to remove the scala_2.12 jar from the flink/lib directory and set the class-loader pattern...

ZachFontenot

Drop Flink 1.18 support to reduce code duplication and improve testability

5

Hi @novakov-alexey, You told me a few weeks ago you were looking for a way to improve testing for Flink1 and Flink2 without duplicating the tests. I think the way...

arnaud-daroussin

Add the possibility to handle state evolution without breaking state compatibility

5

Hi @novakov-alexey, I noticed several `SerializerSnapshot` cannot handle evolutions that break serialization backward compatibility because they don't serialize their version number. And so when reading back the serialized stream, they...

arnaud-daroussin

## About this PR 📦 Updates * [org.scala-lang:scala-library](https://github.com/scala/scala) * [org.scala-lang:scala-reflect](https://github.com/scala/scala) from `2.13.17` to `2.13.18` 📜 [GitHub Release Notes](https://github.com/scala/scala/releases/tag/v2.13.18) - [Version Diff](https://github.com/scala/scala/compare/v2.13.17...v2.13.18) ## Usage ✅ **Please merge!** I'll automatically update this...

scala-steward

Add more serializers

3

Hi @novakov-alexey, Now that the reunification of Flink 1 and 2 is complete, I’m opening this ticket to discuss the serializers we wrote for our needs and that we can...

arnaud-daroussin

Handle recursive types

1

Currently, our generic `CaseClassTypeInfo` and `CaseClassSerializer` don't handle recursive case classes. This issue is created from PR discussions in https://github.com/flink-extended/flink-scala-api/pull/280. I was able to hack something in `LowPrioImplicits` thanks to...

arnaud-daroussin

Separate type-information derivation into auto and semiauto

5

Before I start explaining: I'm willing to work on the PR if you're interested, but I thought it better to discuss it with you first :-) So, we're using flink-scala-api...

gaelrenoux-datadome