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

Review request for samza, Yan Fang, Chinmay Soman, Chris Riccomini, Navina 
Ramesh, and Naveen Somasundaram.


Bugs: SAMZA-608
    https://issues.apache.org/jira/browse/SAMZA-608


Repository: samza


Description
-------

SAMZA-608: fix system consumer stuck issue when discarding the serde exception


Diffs
-----

  samza-core/src/main/scala/org/apache/samza/system/SystemConsumers.scala 
125d37602e2c0a9da75674f37580a1ac02f94796 
  samza-core/src/test/scala/org/apache/samza/system/TestSystemConsumers.scala 
3fdc781c1275f928f4b51b01869e1122502a2c08 

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


Testing
-------

passed local unit tests.


Thanks,

Yi Pan (Data Infrastructure)

Reply via email to