From b34a32db515697eb06b85dbfbd10cee2b4fb0ab6 Mon Sep 17 00:00:00 2001 From: Marvin Date: Wed, 11 Dec 2024 08:13:59 -0300 Subject: [PATCH] Fix java type for event_time (#1023) Signed-off-by: Marvin Froeder --- .../java/com/datasqrl/graphql/MutationConfigurationImpl.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/sqrl-server/sqrl-server-vertx/src/main/java/com/datasqrl/graphql/MutationConfigurationImpl.java b/sqrl-server/sqrl-server-vertx/src/main/java/com/datasqrl/graphql/MutationConfigurationImpl.java index 6ebb3a59f..860859519 100644 --- a/sqrl-server/sqrl-server-vertx/src/main/java/com/datasqrl/graphql/MutationConfigurationImpl.java +++ b/sqrl-server/sqrl-server-vertx/src/main/java/com/datasqrl/graphql/MutationConfigurationImpl.java @@ -69,7 +69,7 @@ public DataFetcher visit(KafkaMutationCoords coords, Context context) { .onSuccess(sinkResult->{ //Add timestamp from sink to result ZonedDateTime dateTime = ZonedDateTime.ofInstant(sinkResult.getSourceTime(), ZoneOffset.UTC); - entry.put(ReservedName.MUTATION_TIME.getCanonical(), dateTime.toLocalDateTime()); + entry.put(ReservedName.MUTATION_TIME.getCanonical(), dateTime.toOffsetDateTime()); fut.complete(entry); })