[ https://issues.apache.org/jira/browse/APEXCORE-649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15874938#comment-15874938 ]
Sanjay M Pujare commented on APEXCORE-649: ------------------------------------------ [~tushargosavi] a comment not directly related to this JIRA but regarding event processing. I have another JIRA https://issues.apache.org/jira/browse/APEXCORE-642 and when I investigated this I realized that the Stram Event listener/processor doesn't get initialized unless the DAG is properly deserialized and constructed in the StreamingAppMasterService.serviceInit(). This precludes creation of error events that happen in that phase. So for this JIRA, it will be useful if this issue is addressed ie. the event listener system is initialized as early as possible and is not dependent on the DAG being properly constructed. > Infrastructure for user define stram event listeners. > ----------------------------------------------------- > > Key: APEXCORE-649 > URL: https://issues.apache.org/jira/browse/APEXCORE-649 > Project: Apache Apex Core > Issue Type: Sub-task > Reporter: Tushar Gosavi > Assignee: Tushar Gosavi > > As suggested while working on Visitor API, I have came up with following > proposal. The idea is to support user defined DAG listeners. The plan is to > support limitated set of events for now and we could add more events > in future. > For the details functionality propvided check attached document. > Please provide feedback on provided proposal. > https://docs.google.com/document/d/1SAIE0EjnCumrB1jKJSnbGvcml47Po8ZHFthfcbNJQgU/edit?usp=sharing -- This message was sent by Atlassian JIRA (v6.3.15#6346)