[incubator-gobblin] branch master updated: [GOBBLIN-914] accept more tracking events in gaas

[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 21459db  [GOBBLIN-914] accept more tracking events in gaas
21459db is described below

commit 21459db15a2869805b5d515819cf0b037acef408
Author: Arjun Bora <ab...@abora-ld1.linkedin.biz>
AuthorDate: Wed Oct 16 21:59:09 2019 -0700

    [GOBBLIN-914] accept more tracking events in gaas
    
    Closes #2767 from arjun4084346/events
---
 .../org/apache/gobblin/service/monitoring/KafkaAvroJobStatusMonitor.java | 1 +
 1 file changed, 1 insertion(+)

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 e021af0..9cc3674 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
@@ -132,6 +132,7 @@ public class KafkaAvroJobStatusMonitor extends 
KafkaJobStatusMonitor {
       case TimingEvent.LauncherTimings.JOB_ORCHESTRATED:
         properties.put(JobStatusRetriever.EVENT_NAME_FIELD, 
ExecutionStatus.ORCHESTRATED.name());
         break;
+      case TimingEvent.LauncherTimings.JOB_PREPARE:
       case TimingEvent.LauncherTimings.JOB_START:
         properties.put(JobStatusRetriever.EVENT_NAME_FIELD, 
ExecutionStatus.RUNNING.name());
         properties.put(TimingEvent.JOB_START_TIME, 
properties.getProperty(TimingEvent.METADATA_END_TIME));