handle job cancellation case in status monitor
Closes from arjun4084346/bugInFlowStatus
@@ -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;
}
