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

Posted to dev@gobblin.apache.org by "Arjun Singh Bora (Jira)" <ji...@apache.org> on 2021/04/23 21:37:00 UTC

[jira] [Created] (GOBBLIN-1437) Segregate FlowConfigs/Delete and FlowExecutions/Delete functions #3268

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)