samza-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Jake Maes <jacob.m...@gmail.com>
Subject Review Request 45339: SAMZA-913 CoordinatorStreamSystemConsumer drops messages when they are considered equivalent
Date Fri, 25 Mar 2016 18:15:58 GMT

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

Review request for samza.


Repository: samza


Description
-------

SAMZA-913 CoordinatorStreamSystemConsumer drops messages when they are considered equivalent


Diffs
-----

  samza-core/src/main/java/org/apache/samza/coordinator/stream/CoordinatorStreamSystemConsumer.java
e1a7626de9ca78ffbffeab65a69605e748ab4479 
  samza-core/src/test/java/org/apache/samza/coordinator/stream/TestCoordinatorStreamSystemConsumer.java
0e73e18bd55e343e1a5122be7e8f3c666b797dc5 

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


Testing
-------

Added a unit test which fails before the change and passes after. 

Ran check-all.sh

This patch fixed my test job for SAMZA-906


Thanks,

Jake Maes


Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message