TypeMapper is not serializable, cause error when used in Broadcast State

findify / flink-adt

Scala ADT support for Apache Flink

MIT License

51 stars 9 forks source link

TypeMapper is not serializable, cause error when used in Broadcast State #49

Open qingwei91 opened 1 year ago

qingwei91 commented 1 year ago

Hi, I am using scala.math.BigDecimal in broadcast state, and it is not working.

I believe it is caused by TypeMapper which is used to handle java=>scala BigDecimal mapping, and broadcast state required the TypeInfo to be serializable.

I think this can be fixed by making TypeMapper serializable, do you think this is the right fix?

jasiskis commented 1 year ago

Same issue here.