+1 (non-binding) on this design. To me the task-count based groupers should work well in practice for partition expansion of system using hash for partitions, e.g. Kafka. It will not cause any state transfer between hosts so the runtime cost will be minimal. In the future when we support dynamically re-balancing the tasks, we can further scale the task count if needed.
Thanks, Xinyu On Mon, Jun 19, 2017 at 9:27 AM, Dong Lin <lindon...@gmail.com> wrote: > Hi everyone, > > Can you please vote for SEP-5? The wiki can be found at > *https://cwiki.apache.org/confluence/display/SAMZA/SEP- > 5%3A+Enable+partition+expansion+of+input+streams > <https://cwiki.apache.org/confluence/display/SAMZA/SEP- > 5%3A+Enable+partition+expansion+of+input+streams>.* > > Thanks, > Dong >
