From d45c64f516062841339e9ce93e4675257e6e93e8 Mon Sep 17 00:00:00 2001 From: Star Poon Date: Thu, 6 Jun 2024 12:58:32 +0900 Subject: [PATCH] Remove non-null restriction for QueryHistory --- .../io/trino/gateway/ha/persistence/dao/QueryHistory.java | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/gateway-ha/src/main/java/io/trino/gateway/ha/persistence/dao/QueryHistory.java b/gateway-ha/src/main/java/io/trino/gateway/ha/persistence/dao/QueryHistory.java index 09bfdb3d0..3f0293374 100644 --- a/gateway-ha/src/main/java/io/trino/gateway/ha/persistence/dao/QueryHistory.java +++ b/gateway-ha/src/main/java/io/trino/gateway/ha/persistence/dao/QueryHistory.java @@ -13,6 +13,7 @@ */ package io.trino.gateway.ha.persistence.dao; +import jakarta.annotation.Nullable; import org.jdbi.v3.core.mapper.reflect.ColumnName; import static java.util.Objects.requireNonNull; @@ -21,8 +22,8 @@ public record QueryHistory( @ColumnName("query_id") String queryId, @ColumnName("query_text") String queryText, @ColumnName("backend_url") String backendUrl, - @ColumnName("user_name") String userName, - @ColumnName("source") String source, + @ColumnName("user_name") @Nullable String userName, + @ColumnName("source") @Nullable String source, @ColumnName("created") long created) { public QueryHistory @@ -30,7 +31,5 @@ public record QueryHistory( requireNonNull(queryId, "queryId is null"); requireNonNull(queryText, "queryText is null"); requireNonNull(backendUrl, "backendUrl is null"); - requireNonNull(userName, "userName is null"); - requireNonNull(source, "source is null"); } }