SAMZA-1384: Race condition with async commit affects checkpoint correctness
authorJacob Maes <jmaes@linkedin.com>
Thu, 10 Aug 2017 22:44:42 +0000 (15:44 -0700)
committerJacob Maes <jmaes@linkedin.com>
Thu, 10 Aug 2017 22:44:42 +0000 (15:44 -0700)
commit8f7f56744c2824426962e1ca4f382b1877e4a9b0
tree15e58b8b2c09118e1e82b55b58be8bff2d0f34fa
parent403042394945deba1affa7269c7ead3129326cbd
SAMZA-1384: Race condition with async commit affects checkpoint correctness

Author: Jacob Maes <jmaes@linkedin.com>

Reviewers: Prateek Maheshwari <pmaheshw@linkedin.com>

Closes #263 from jmakes/samza-1384
samza-core/src/main/scala/org/apache/samza/checkpoint/OffsetManager.scala
samza-core/src/main/scala/org/apache/samza/container/TaskInstance.scala
samza-core/src/test/java/org/apache/samza/task/TestAsyncRunLoop.java
samza-core/src/test/scala/org/apache/samza/checkpoint/TestOffsetManager.scala
samza-core/src/test/scala/org/apache/samza/container/TestTaskInstance.scala