Call duplicate when type is not immutable

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

68 stars 14 forks source link

Call duplicate when type is not immutable #114

Closed novakov-alexey closed 6 months ago

novakov-alexey commented 6 months ago

Additional change for some of the TypeInfos to call duplicate serializers when they are not immutable.

FYI @sonowz

sonowz commented 6 months ago

Being immutable and being thread-safe seems slightly different, but it looks fair enough to me. At least we have a way to let mutable types call duplicate() :+1: