flink-extended / flink-scala-api

Flink Scala API is a thin wrapper on top of Flink Java API which support Scala Types for serialisation as well the latest Scala version
Apache License 2.0
69 stars 15 forks source link

Make TypeMapper trait serializable #82

Closed buinauskas closed 9 months ago

buinauskas commented 9 months ago

Should solve https://github.com/flink-extended/flink-scala-api/issues/81

I am not entirely sure if the spec spinning the whole execution environment is supposed to be under the mapped type info test, but it felt like the right place because of the problem scope. Let me know if something needs fixing.

novakov-alexey commented 9 months ago

Cool, checking build.

novakov-alexey commented 9 months ago

Releasing this fix today.