Arjun Singh Bora created GOBBLIN-1437:
-----------------------------------------

             Summary: Segregate FlowConfigs/Delete and FlowExecutions/Delete 
functions #3268
                 Key: GOBBLIN-1437
                 URL: https://issues.apache.org/jira/browse/GOBBLIN-1437
             Project: Apache Gobblin
          Issue Type: Bug
            Reporter: Arjun Singh Bora


there are some mixup of work in FlowConfigs/Delete and FlowExecutions/Delete 
which is to be fixed

FlowConfigs/Delete

1) is not cancelling the current running execution on cluster (i.e. when 
KafkaSpecProducer is used)

2) is not deleting state store when DagManager is used and KafkaSpecProducer is 
used

FlowExecutions/Delete

1) is not calling SpecProducer.cancel() 

2) is deleting the state store when KafkaSpecProducer is used, because cluster 
thinks it is a DELETE request



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to