-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/47761/
-----------------------------------------------------------
Review request for samza.
Bugs: SAMZA-856
https://issues.apache.org/jira/browse/SAMZA-856
Repository: samza
Description
-------
Added optionally checkpointing based on number of processed messages per
container, task or per system stream.
Diffs
-----
docs/learn/documentation/versioned/container/checkpointing.md
6f8c6d694be92f973af456ddd518d70540abe5c3
docs/learn/documentation/versioned/jobs/configuration-table.html
c1c822e03ce960c69b07eb44409a9af018823ef6
samza-core/src/main/scala/org/apache/samza/config/TaskConfig.scala
08a4debb06f9925ae741049abb2ee0df97b2243b
samza-core/src/main/scala/org/apache/samza/container/RunLoop.scala
6916c5c71e479d43a7435fa4987565d93ed437ac
samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala
bcbc90a0a460f8733e6d3a50dbc33f3720cad7d0
samza-core/src/main/scala/org/apache/samza/container/SamzaContainerMetrics.scala
6fae6509d177cc3a54dac9ad1d3e5cc479f4a4f5
samza-core/src/main/scala/org/apache/samza/container/TaskInstance.scala
d32a92976e43ca24033b48c91851ee706de7de6b
samza-core/src/main/scala/org/apache/samza/coordinator/JobCoordinator.scala
cd7daa2f2be9e7f1f2fea8e3035c8f6c6f420e95
samza-core/src/test/scala/org/apache/samza/container/TestRunLoop.scala
ad3744711cc5ef17b5d3a45eb7b567956d77453a
samza-core/src/test/scala/org/apache/samza/container/TestSamzaContainer.scala
9df12d2974c686c07457b29d873fd3e9dab72e21
Diff: https://reviews.apache.org/r/47761/diff/
Testing
-------
Ran unit tests "./gradlew clean build"
"./gradlew checkstyleMain checkstyleTest"
Tested on modified hello-samza with supported checkpointing and partitioned
streams.
Thanks,
Branislav Cogic
