Hamid, would you mind creating a Jira? Thanks.
-Matthias On 11/28/16 9:36 AM, Guozhang Wang wrote: > Damian, Hamid: > > I looked at the source code and suspect that it is because of the > auto-repartitioning which causes the topology to not directly forward the > record to the child processors but send to an intermediate topic. In our > tests we only do "groupByKey" without map, and hence auto-repartitioning > will not be introduced. > > What bothers me is that, for KStreamTestDriver it should have the similar > issue as well (it does not handle intermediate topic either), but Hamid > reports it actually works fine. > > Anyways, I think there is an issue with at least ProcessorTopologyTestDriver, > and very likely with KStreamTestDriver as well, and we should file a JIRA > and continue investigating and fixing it. > > > Guozhang > > > On Thu, Nov 24, 2016 at 7:34 AM, Hamidreza Afzali < > hamidreza.afz...@hivestreaming.com> wrote: > >> Hi Damian, >> >> It processes correctly when using KStreamTestDriver. >> >> Best, >> Hamid >> >> > >
signature.asc
Description: OpenPGP digital signature
