----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23235/ -----------------------------------------------------------
Review request for samza. Repository: samza Description ------- Support dropping messages on serde failures. 1. added a task property: task.drop.deserialization.errors . If set to true, the system will skip error messages. If set to false, will throw exceptions. 2. use try/catch to wrap butter.update in SystemConsumers. 3. added method in TaskConfig. 4. added Test method in TestSystemConsumers 5. updated the configuration page to include the new property. Diffs ----- docs/learn/documentation/0.7.0/jobs/configuration-table.html 07cb83f samza-core/src/main/scala/org/apache/samza/config/TaskConfig.scala 18a9510 samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala 356adbb samza-core/src/main/scala/org/apache/samza/system/SystemConsumers.scala b537046 samza-core/src/test/scala/org/apache/samza/system/TestSystemConsumers.scala e1a4c15 Diff: https://reviews.apache.org/r/23235/diff/ Testing ------- Thanks, Yan Fang
