It's my understanding that a group by is also a key by under the hood. As a result that will cause a shuffle operation to happen. Our source is a Kafka topic that is keyed so that any give partition contains all the data that is needed for any given consuming TM. Is there a way using FlinkSQL to eliminate the shuffle operation? Or I'm missing details other details that would make such a change undesirable?
Thank you, Aeden