Repository: samza Updated Branches: refs/heads/master a6ada1f6f -> 9a9ab8d24
SAMZA-567; allow stores to work from init method Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/9a9ab8d2 Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/9a9ab8d2 Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/9a9ab8d2 Branch: refs/heads/master Commit: 9a9ab8d243a940701cf8b6374b15d507a484f491 Parents: a6ada1f Author: Naveen Somasundaram <[email protected]> Authored: Wed Mar 18 18:50:46 2015 -0700 Committer: Chris Riccomini <[email protected]> Committed: Wed Mar 18 18:50:46 2015 -0700 ---------------------------------------------------------------------- .../main/scala/org/apache/samza/container/SamzaContainer.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/samza/blob/9a9ab8d2/samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala ---------------------------------------------------------------------- diff --git a/samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala b/samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala index 87fcf58..9fc3b55 100644 --- a/samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala +++ b/samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala @@ -541,8 +541,8 @@ class SamzaContainer( startMetrics startOffsetManager startStores - startTask startProducers + startTask startConsumers info("Entering run loop.") @@ -555,8 +555,8 @@ class SamzaContainer( info("Shutting down.") shutdownConsumers - shutdownProducers shutdownTask + shutdownProducers shutdownStores shutdownOffsetManager shutdownMetrics
