You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by cr...@apache.org on 2015/04/08 01:25:51 UTC
[19/36] samza git commit: SAMZA-567;
allow stores to work from init method
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/samza-sql
Commit: 9a9ab8d243a940701cf8b6374b15d507a484f491
Parents: a6ada1f
Author: Naveen Somasundaram <na...@gmail.com>
Authored: Wed Mar 18 18:50:46 2015 -0700
Committer: Chris Riccomini <cr...@apache.org>
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