Hi, I was trying to test some specific issue, but now I cannot seem to get the very basic case working. It is most likely that I am blind to something, would anyone have quick look at it? https://gist.github.com/rami-alisawi/d6ff33ae2d4d6e7bb1f8b329e3e5fa77
It is just a collection of pojos where I am just trying to keyBy one field and sum into the other, but I am getting: 5> PojoExample{count=0, productId='productA'} 8> PojoExample{count=0, productId='productB'} 5> PojoExample{count=0, productId='productA'} 8> PojoExample{count=0, productId='productB'} 5> PojoExample{count=0, productId='productA'} 5> PojoExample{count=0, productId='productA'} 5> PojoExample{count=0, productId='productA’} Regards, -Rami Disclaimer: This message and any attachments thereto are intended solely for the addressed recipient(s) and may contain confidential information. If you are not the intended recipient, please notify the sender by reply e-mail and delete the e-mail (including any attachments thereto) without producing, distributing or retaining any copies thereof. Any review, dissemination or other use of, or taking of any action in reliance upon, this information by persons or entities other than the intended recipient(s) is prohibited. Thank you.