Github user azagrebin commented on the issue: https://github.com/apache/flink/pull/6196 @StefanRRichter @sihuazhou Thanks guys for the helpful review. I refactored the `CompositeSerializer` to rely rather on loops than streams and added tests for it. Please, have a look. cc @twalthr Maybe, the implementation of `CompositeSerializer` in this PR could be potentially interesting for other complex types, e.g. tuples or pojos allowing code reuse where it is possible without performance loss.
---