Hi all, We’re working on FLINK-5734 : Implement code generation for NormalizedKeySorter. We have just finished a design document that describes how we’re going to proceed this implementation.
Because this implement will touch several important parts of Flink, so we would appreciate if you could give us some feedback before starting implementation. Here is the link to the document : https://docs.google.com/document/d/1anGQhBn9qI0yqe7twVvrDIiym4U4gxalJkZzM4Ar4QM/edit?usp=sharing <https://docs.google.com/document/d/1anGQhBn9qI0yqe7twVvrDIiym4U4gxalJkZzM4Ar4QM/edit?usp=sharing> Also, we would like to confirm that NormalizedKeySorter is always instantiated at TaskManager, but we could not find any solution to verify that yet. If you know how to do it, we would be very pleased to hear that. Thank you in advance for your feedback. Best regards, Serkan, Gábor and Pat
