flink-scala-api

flink-scala-api copied to clipboard

Fixes #111 I made sure that all subclasses of `TypeInformation` in this repository creates a new instance of `TypeSerializer` when `.createSerializer()` method is called. Besides, while working on it I...

sonowz

Hi, I stumbled upon the race conditions in a app using this library. ## Description As far as I know, `TypeInformation` class is okay to be used as singleton, whereas...

sonowz

Possible case class serialization/deserialization bug

1

I have been using your library for many months without any issues, and thanks for making this project available, however I am encountering a weird issue with a MatchError on...

BjarkeTornager

In one of the recent release we added new functionality to allow case classes to evolve schemas. #80 This issue is a TODO to describe what case class changes are...

novakov-alexey

## About this PR 📦 Updates [ch.qos.logback:logback-classic](https://github.com/qos-ch/logback) from `1.5.6` to `1.5.7` ## Usage ✅ **Please merge!** I'll automatically update this PR to resolve conflicts as long as you don't change...

scala-steward

In order to improve the understanding of this library and Apache Flink for those who have never tried it before, I think a directory in the repo with code examples...

geazi-anc

Savepoint incompatibility between 1.1.4 and 1.1.5

15

After upgrading this library from 1.1.4 to 1.1.5 we've noticed that savepoints made while using older version became incompatible with the job containing newer version. After digging in, I've traced...

IgnasD

In order to reduce time for the release process and get rid of obsolete code related to Scala 2.12. Please share your feedback if build for Scala 2.12 is still...

novakov-alexey

`scala.MatchError: None (of class scala.None$)` during `CaseClassSerializer`

5

Direct follow up from #106, but I figured a new issue would be helpful. Using ` "1.18.1_1.1.5"` w/ scala `3.4.0` on AWS' managed Flink (i.e., little control over their setup)...

chollinger93