Validate no delete deltas for a non full ACID table

trinodb · Jun 14, 2021 · 54935cb · 54935cb
1 parent 3538624
commit 54935cb
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/plugin/trino-hive/src/main/java/io/trino/plugin/hive/BackgroundHiveSplitLoader.java b/plugin/trino-hive/src/main/java/io/trino/plugin/hive/BackgroundHiveSplitLoader.java
@@ -526,6 +526,12 @@ private ListenableFuture<?> loadPartition(HivePartitionMetadata partition)
             // Create a registry of delete_delta directories for the partition
             for (AcidUtils.ParsedDelta delta : directory.getCurrentDirectories()) {
                 if (delta.isDeleteDelta()) {
+                    if (!isFullAcid) {
+                        throw new TrinoException(HIVE_BAD_DATA, format(
+                                "Unexpected delete delta for a non full ACID table '%s'. Would be ignored by the reader: %s",
+                                table.getSchemaTableName(),
+                                delta.getPath()));
+                    }
                     acidInfoBuilder.addDeleteDelta(delta.getPath());
                 }
             }