From 6ae44db67beff8695dc9dbc87f5fedd20e9adcc6 Mon Sep 17 00:00:00 2001 From: phixMe Date: Tue, 8 Oct 2024 12:27:46 -0700 Subject: [PATCH] Fixing removed refs. Signed-off-by: phixMe --- api/src/main/java/marquez/api/OpenLineageResource.java | 8 -------- 1 file changed, 8 deletions(-) diff --git a/api/src/main/java/marquez/api/OpenLineageResource.java b/api/src/main/java/marquez/api/OpenLineageResource.java index 20a438398c..bb813b8fc8 100644 --- a/api/src/main/java/marquez/api/OpenLineageResource.java +++ b/api/src/main/java/marquez/api/OpenLineageResource.java @@ -16,8 +16,6 @@ import com.fasterxml.jackson.core.JsonProcessingException; import io.dropwizard.jersey.jsr310.ZonedDateTimeParam; import java.sql.SQLException; -import java.time.Instant; -import java.time.ZoneId; import java.util.Collections; import java.util.List; import java.util.concurrent.CompletionException; @@ -70,12 +68,6 @@ public OpenLineageResource( public void create(@Valid @NotNull BaseEvent event, @Suspended final AsyncResponse asyncResponse) throws JsonProcessingException, SQLException { if (event instanceof LineageEvent) { - - Instant eventTime = - ((LineageEvent) event).getEventTime().withZoneSameInstant(ZoneId.of("UTC")).toInstant(); - String eventType = ((LineageEvent) event).getEventType(); - serviceFactory.getStatsService().createCurrentDayLineageMetric(eventTime, eventType); - serviceFactory.getStatsService().createCurrentHourLineageMetric(eventTime, eventType); if (serviceFactory.getSearchService().isEnabled()) { serviceFactory.getSearchService().indexEvent((LineageEvent) event); }