[
https://issues.apache.org/jira/browse/SAMZA-1125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15900404#comment-15900404
]
Xinyu Liu commented on SAMZA-1125:
----------------------------------
run is a blocking call, but shutdown will not wait until the container finishes
shutdown. So unless we allow the new container starts while the previous
container is till shutting down, we need some waiting here.
> Container.shutdown() only stops the runloop
> -------------------------------------------
>
> Key: SAMZA-1125
> URL: https://issues.apache.org/jira/browse/SAMZA-1125
> Project: Samza
> Issue Type: New Feature
> Reporter: Xinyu Liu
> Assignee: Navina Ramesh
>
> Currently SamzaContainer.shutdown() only stops the RunLoop. Seems to me all
> the dependencies used by the container are not properly shutdown. E.g. the
> kafka system consumer/producer will not be shut down. In standalone case
> (ZkJobCoordinator.java), the next time controller.startContainer() will
> create the container with all these dependencies again. The Kafka
> producers/consumers will be created again without closing the previous ones.
> Please verify this is a problem and needs to be fixed.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
