Remove non-null restriction for QueryHistory

trinodb · Jun 6, 2024 · d45c64f · d45c64f
1 parent a5390e6
commit d45c64f
Showing 1 changed file with 3 additions and 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
@@ -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,16 +22,14 @@ 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
     {
         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");
     }
 }