Re: Review Request 37506: WIP: SAMZA-552 Operator API change: New Builder API

> On Aug. 24, 2015, 8:35 a.m., Yi Pan (Data Infrastructure) wrote: > > Hi, Milinda, sorry for the late review. I have put down my comments below. > > Overall, there are two things to be discussed: > > 1) Adding OperatorBuilder interface as well. It serves two purposes: > >a) I remember that

Re: Review Request 37506: WIP: SAMZA-552 Operator API change: New Builder API

> On Aug. 24, 2015, 8:35 a.m., Yi Pan (Data Infrastructure) wrote: > > samza-sql-core/src/test/java/org/apache/samza/task/sql/StreamSqlTask.java, > > line 89 > > > > > > The goal here is to use the topology builder t

Re: One task sending payload to multiple output streams

Hi Elangovan, I think not providing the partition key is the reason. Can you try to put the partition key, such as 0,1,2,4 to see how it works? This uses the default partition class. For better control, you may provide your own partition class. This is to demonstrate the cause of your problem. Th