@Yogi, If you are up for the small experiment and share some latency number with us, It will help improve the unifiers.
1. Avoid M*1 unifiers 2. Use the mentioned PR to launch your application with the unifiers, https://github.com/apache/apex-core/pull/358/ On Mon, Jul 25, 2016 at 11:47 PM Ashwin Chandra Putta < ashwinchand...@gmail.com> wrote: > Yogi, > What is the reason for avoiding unifiers? > > Regards, > Ashwin. > > On Mon, Jul 25, 2016 at 9:41 AM, Yogi Devendra <yogideven...@apache.org> > wrote: > >> Hi, >> >> I have a DAG A->B->C. >> >> 1. A is kafka input operator reading from 4 different topics configured >> with ONE_TO_ONE strategy. Thus creating 4 partitons of A. >> 2. B and C are configured to have parallel partitions w.r.t. their input >> port. Thus, currently both B, C have 4 partitions. >> >> I am observing B significant latency in B operator. Thus, would like to >> have 2 partitions for B per partition of A. Since, application is latency >> intensive, I want to avoid unifiers as far as possible. >> >> How to achieve this partitioning? >> >> >> ~ Yogi >> > > > > -- > > Regards, > Ashwin. >
