[incubator-gobblin] branch master updated: [GOBBLIN-773] handle job cancellation case in status monitor

[suvasude]

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 a87e2e3  [GOBBLIN-773] handle job cancellation case in status monitor
a87e2e3 is described below

commit a87e2e3c521a72279537e74f775fe2862ee1fda2
Author: Arjun <ab...@linkedin.com>
AuthorDate: Thu May 16 20:29:40 2019 -0700

    [GOBBLIN-773] handle job cancellation case in status monitor
    
    Closes #2638 from arjun4084346/bugInFlowStatus
---
 .../apache/gobblin/service/monitoring/KafkaAvroJobStatusMonitor.java  | 4 ++++
 1 file changed, 4 insertions(+)

diff --git 
a/gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/KafkaAvroJobStatusMonitor.java
 
b/gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/KafkaAvroJobStatusMonitor.java
index 5aa1a16..fe4d171 100644
--- 
a/gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/KafkaAvroJobStatusMonitor.java
+++ 
b/gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/KafkaAvroJobStatusMonitor.java
@@ -141,6 +141,10 @@ public class KafkaAvroJobStatusMonitor extends 
KafkaJobStatusMonitor {
         properties.put(JobStatusRetriever.EVENT_NAME_FIELD, 
ExecutionStatus.FAILED.name());
         properties.put(TimingEvent.JOB_END_TIME, 
properties.getProperty(TimingEvent.METADATA_END_TIME));
         break;
+      case TimingEvent.LauncherTimings.JOB_CANCEL:
+        properties.put(JobStatusRetriever.EVENT_NAME_FIELD, 
ExecutionStatus.CANCELLED.name());
+        properties.put(TimingEvent.JOB_END_TIME, 
properties.getProperty(TimingEvent.METADATA_END_TIME));
+        break;
       default:
         return null;
     }