[incubator-gobblin] branch master updated: [GOBBLIN-1306] add uri in spec producer deletespec call

[su...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

suvasude pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-gobblin.git


The following commit(s) were added to refs/heads/master by this push:
     new 58fbf67  [GOBBLIN-1306] add uri in spec producer deletespec call
58fbf67 is described below

commit 58fbf67b6065a373ab1e8afd427b75612ee65370
Author: Arjun <ab...@linkedin.com>
AuthorDate: Mon Nov 2 09:25:08 2020 -0800

    [GOBBLIN-1306] add uri in spec producer deletespec call
    
    Closes #3144 from arjun4084346/deleteURI
---
 .../org/apache/gobblin/service/modules/orchestration/DagManager.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/DagManager.java b/gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/DagManager.java
index e84185f..914ebb5 100644
--- a/gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/DagManager.java
+++ b/gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/DagManager.java
@@ -492,7 +492,7 @@ public class DagManager extends AbstractIdleService {
         props.put(ConfigurationKeys.SPEC_PRODUCER_SERIALIZED_FUTURE, serializedFuture);
         sendCancellationEvent(dagNodeToCancel.getValue());
       }
-      DagManagerUtils.getSpecProducer(dagNodeToCancel).deleteSpec(null, props);
+      DagManagerUtils.getSpecProducer(dagNodeToCancel).deleteSpec(dagNodeToCancel.getValue().getJobSpec().getUri(), props);
     }
 
     private void sendCancellationEvent(JobExecutionPlan jobExecutionPlan) {