diff --git a/api/all.yaml b/api/all.yaml index dbe8c068c..ff8950e61 100644 --- a/api/all.yaml +++ b/api/all.yaml @@ -2394,6 +2394,12 @@ components: Metadata: description: Represents a Delta metadata action (see https://github.com/delta-io/delta/blob/master/PROTOCOL.md#change-metadata for more information). properties: + name: + type: string + description: User-provided identifier for this table. (should be set if changed). + description: + type: string + description: User-provided description for this table. (should be set if changed). delta_table_id: type: string description: The table ID (this is the internal table ID created by Delta). diff --git a/server/src/main/java/io/unitycatalog/server/persist/dao/CommitDAO.java b/server/src/main/java/io/unitycatalog/server/persist/dao/CommitDAO.java index 2cd25aabc..c575a1f5c 100644 --- a/server/src/main/java/io/unitycatalog/server/persist/dao/CommitDAO.java +++ b/server/src/main/java/io/unitycatalog/server/persist/dao/CommitDAO.java @@ -12,7 +12,7 @@ @Table( name = "uc_commits", uniqueConstraints = { - @UniqueConstraint(columnNames = {"metastore_id", "table_id", "commit_version"}) + @UniqueConstraint(columnNames = {"table_id", "commit_version"}) }) // Lombok @Getter @@ -44,7 +44,7 @@ public class CommitDAO { @Column(name = "commit_timestamp", nullable = false) private Date commitTimestamp; - @Column(name = "is_backfilled_latest_commit") + @Column(name = "is_backfilled_latest_commit", nullable = false) private Boolean isBackfilledLatestCommit; @Column(name = "is_disown_commit") diff --git a/server/src/main/java/io/unitycatalog/server/persist/utils/FileUtils.java b/server/src/main/java/io/unitycatalog/server/persist/utils/FileUtils.java index 6c53a4822..e97ee4394 100644 --- a/server/src/main/java/io/unitycatalog/server/persist/utils/FileUtils.java +++ b/server/src/main/java/io/unitycatalog/server/persist/utils/FileUtils.java @@ -112,7 +112,7 @@ private static void deleteLocalDirectory(Path dirPath) throws IOException { }); } } else { - LOGGER.info("Directory does not exist: {}", dirPath); + throw new IOException("Directory does not exist: " + dirPath); } }