Re: [VOTE] SEP-5: Enable partition expansion of input streams

Thanks everyone, especially Navina, Yi, Jacob and Xinyu for your comments! Since Yi has voted +1 in the discussion thread, this SEP is now adopted with two binding votes (Yi, Navina) and one non-binding committer vote (Xinyu). Thanks again! Dong On Fri, Jun 23, 2017 at 5:33 PM, Navina Ramesh (

Re: [VOTE] SEP-5: Enable partition expansion of input streams

After a lot of Q&A, let's get this done :) +1 (binding) Thanks! Navina On Tue, Jun 20, 2017 at 10:31 AM, xinyu liu wrote: > +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.

Re: [VOTE] SEP-5: Enable partition expansion of input streams

After a lot of Q&A, let's get this done :) +1 (binding) Thanks! Navina On Tue, Jun 20, 2017 at 10:31 AM, xinyu liu wrote: > +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.

Re: [VOTE] SEP-5: Enable partition expansion of input streams

+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 dynamical

[VOTE] SEP-5: Enable partition expansion of input streams

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 .* Thanks, Dong