You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@samza.apache.org by "Prateek Maheshwari (JIRA)" <ji...@apache.org> on 2017/05/19 20:34:04 UTC

[jira] [Created] (SAMZA-1300) Init and close for Functions and ContextManager in a StreamApplication should only be called once per ApplicationRunner

Prateek Maheshwari created SAMZA-1300:
-----------------------------------------

             Summary: Init and close for Functions and ContextManager in a StreamApplication should only be called once per ApplicationRunner
                 Key: SAMZA-1300
                 URL: https://issues.apache.org/jira/browse/SAMZA-1300
             Project: Samza
          Issue Type: Bug
            Reporter: Prateek Maheshwari
             Fix For: 0.14.0


Currently Function and ContextManager init is called per instance of the StreamOperatorTask. 

When using an StreamApplication with the LocalApplicationRunner + ZkJobCoordinator, SamzaContainers are recycled when the JobModel is updated. 

This will lead to init and close being called for Functions and ContextManager multiple times during the ApplicationRunner and StreamApplication lifecycle. This needs to be fixed.



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)