[ https://issues.apache.org/jira/browse/APEXCORE-408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15958879#comment-15958879 ]
Tushar Gosavi commented on APEXCORE-408: ---------------------------------------- [~thw] I have opened a pull request https://github.com/apache/apex-core/pull/476 for statslistener changes. I am implementing the second approach from the document as it would be simple and won't change existing code much. There are few problems I am facing regarding the validation done by LogicalPlan while elements are being added to it, like extending a stream the port needs to be present in the DAG. When I try to extend an existing stream with new operator's input port , as new operator's input port is not in the original DAG , it throws as error as port does not belong to any operator in the DAG. Trying to solve this problem. > Ability to schedule Sub-DAG from running application > ---------------------------------------------------- > > Key: APEXCORE-408 > URL: https://issues.apache.org/jira/browse/APEXCORE-408 > Project: Apache Apex Core > Issue Type: Sub-task > Reporter: Thomas Weise > Assignee: Tushar Gosavi > > Today it is possible to add operators to a running application from the > CLI/client. It should be possible to do this from within the application > also. This can be used to expand/remove a Sub-DAG on demand, triggered by > application specific logic. It will enable use cases such as batch > applications that perform multiple stages of processing where not all > resources are required at the same time or the logic of subsequent steps > depends on the execution of previous steps. -- This message was sent by Atlassian JIRA (v6.3.15#6346)