flink-scala-api icon indicating copy to clipboard operation
flink-scala-api copied to clipboard

Published 20 hours ago • verified publisher icon flink-extended

Fix concurrency bug in subclasses of TypeInformation

Open sonowz opened this issue 9 months ago • 0 comments

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 found that the most of the TypeSerializers in this repository have incorrect method implementations (duplicate, copy, isImmutableType, etc.) They could lead to undesirable behaviors when utilized by Flink. I'll try to fix them when I have some time to do it.

sonowz avatar May 01 '24 04:05 sonowz