Hi all, I need to be able to control which slot a keyBy group goes to, in order to compensate for a badly skewed dataset.
Any recommended approach to use here? Previously (with a DataSet) I used groupBy followed by a withPartitioner, and provided my own custom partitioner. I posted this same question to https://stackoverflow.com/questions/71357833/equivalent-of-dataset-groupby-withpartitioner-for-datastream <https://stackoverflow.com/questions/71357833/equivalent-of-dataset-groupby-withpartitioner-for-datastream> Thanks, — Ken -------------------------- Ken Krugler http://www.scaleunlimited.com Custom big data solutions Flink, Pinot, Solr, Elasticsearch
