You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@samza.apache.org by Aleksandar Pejakovic <a....@levi9.com> on 2015/06/04 16:06:46 UTC

Review Request 35068: SAMZA-699 CoordinatorStreamMessages lose orders in CoordinatorStreamSystemConsumer

-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/35068/
-----------------------------------------------------------

Review request for samza.


Repository: samza


Description
-------

Fix for issue described in [SAMZA-699](https://issues.apache.org/jira/browse/SAMZA-699):

   changed HashSet to LinkedHashSet in CoordinatorStreamSystemConsumer for both bootstrappedStreamSet and bootstrappedStream


Diffs
-----

  samza-core/src/main/java/org/apache/samza/coordinator/stream/CoordinatorStreamSystemConsumer.java 27e0750 
  samza-core/src/test/java/org/apache/samza/coordinator/stream/TestCoordinatorStreamSystemConsumer.java 2fe872b 

Diff: https://reviews.apache.org/r/35068/diff/


Testing
-------

Extended TestCoordinatorStreamSystemConsumer to verify the order of Stream Messages


Thanks,

Aleksandar Pejakovic