[
https://issues.apache.org/jira/browse/APEXCORE-560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15592284#comment-15592284
]
Bhupesh Chawda commented on APEXCORE-560:
-----------------------------------------
The motivation for this is scheduling a sub-DAG multiple times to process
different batches. In this flow, a set of operators may be removed and added
multiple times.
If we have an API for removing an operator, the same operator may need to be
added again to the DAG. This fails if the operator is already there in the
logical DAG.
> Logical plan is not changed when all physical partitions of operator are
> removed from DAG
> -----------------------------------------------------------------------------------------
>
> Key: APEXCORE-560
> URL: https://issues.apache.org/jira/browse/APEXCORE-560
> Project: Apache Apex Core
> Issue Type: Bug
> Reporter: Bhupesh Chawda
>
> Throwing a ShutdownException() from an input operator removes them from the
> physical plan, but can still be seen in the logical plan. Ideally the
> corresponding logical operator must also be removed.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
