SAMZA-948: Samza CoordinatorStreamSystemConsumer is not thread-safe
authorJacob Maes <jacob.maes@gmail.com>
Thu, 12 May 2016 18:07:49 +0000 (11:07 -0700)
committerYi Pan (Data Infrastructure) <nickpan47@gmail.com>
Thu, 12 May 2016 18:07:49 +0000 (11:07 -0700)
commit023a7ce233631c14c40ee5241e13a298362d07b2
tree78c020a3330c2728a27441f423616e76826a2782
parenta460a82e366404498bac676a6b41acc27d458992
SAMZA-948: Samza CoordinatorStreamSystemConsumer is not thread-safe
samza-core/src/main/java/org/apache/samza/coordinator/stream/CoordinatorStreamSystemConsumer.java
samza-core/src/main/scala/org/apache/samza/coordinator/JobCoordinator.scala
samza-core/src/test/java/org/apache/samza/coordinator/stream/TestCoordinatorStreamSystemConsumer.java