-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/32407/
-----------------------------------------------------------
(Updated March 25, 2015, 2:24 a.m.)
Review request for samza, Yan Fang, Chinmay Soman, Chris Riccomini, Navina
Ramesh, and Naveen Somasundaram.
Changes
-------
Revised: add more exception callback methods to ExceptionTask interface for
each specific task lifecycle stage. Consolidate invocation of
ExceptionTask.exception() and the configured suppression in a single place.
Bugs: SAMZA-571
https://issues.apache.org/jira/browse/SAMZA-571
Repository: samza
Description (updated)
-------
[SAMZA-571] Adding task interface to allow customized handling of exceptions
from user code in tasks
Just to add the first part: add ExceptionTask interface to allow user to add
code to handle the exceptions from user code in the task's lifecycle: init(),
process(), window(), and close().
Diffs (updated)
-----
samza-api/src/main/java/org/apache/samza/task/ExceptionTask.java PRE-CREATION
samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala
9fc3b557bdcc2756a0ddfed6642deb529936b7a9
samza-core/src/main/scala/org/apache/samza/container/TaskInstance.scala
be0b55ace5b4b9d29f42da17fabac93bb6a25605
samza-core/src/main/scala/org/apache/samza/container/TaskInstanceExceptionHandler.scala
99b729f129344dee7d324d5889a3964c331f6521
samza-core/src/test/scala/org/apache/samza/container/TestTaskInstance.scala
54b4df84f47f818d62ac0361196567ad1f430fde
Diff: https://reviews.apache.org/r/32407/diff/
Testing (updated)
-------
Unit tests added. Pass with ./bin/check-all.sh
Thanks,
Yi Pan (Data Infrastructure)
