}
Preconditions.checkNotNull(flowKey, String.format(
"Can not push event type %s because flowKey is not set", event.getType()));
FlowEventKey eventKey = new FlowEventKey(flowKey, event.getId());
FlowEvent flowEvent = new FlowEvent(eventKey);
flowEvent.setTimestamp(event.getTimestamp());
flowEvent.setFramework(JobDescFactory.getFramework(jobConf));
flowEvent.setType(event.getType().name());
if (eventDataJson != null) {
flowEvent.setEventDataJSON(eventDataJson);
}
hRavenPool.submit(new HRavenEventRunnable(flowEventService, flowEvent));
}