Hello,

Does Flink serialize all the data when moving from one operator to another 
(even when there is no shuffling/hashing between them)?

If yes, then, does it worth to have less operators doing more stuff instead of 
more granular operators? For instance, one flat map + one filter could be 
substituted with one flat map containing the filtering logic inside. That would 
minimize the serialization/deserialization between those two operators.

It that so? Is that a recommended approach? Will that decrease GC?

Thanks,
Vadim.

Reply via email to