----------------------------------------------------------- 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
