add

apache · Feb 29, 2024 · e0500a5 · e0500a5
1 parent 530fc85
commit e0500a5
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 0 deletions.
diff --git a/...talog-hive/src/main/java/com/datastrato/gravitino/catalog/hive/HiveCatalogOperations.java b/...talog-hive/src/main/java/com/datastrato/gravitino/catalog/hive/HiveCatalogOperations.java
@@ -810,6 +810,9 @@ public Table alterTable(NameIdentifier tableIdent, TableChange... changes)
           } else if (change instanceof TableChange.UpdateColumnType) {
             doUpdateColumnType(cols, (TableChange.UpdateColumnType) change);
 
+          } else if (change instanceof TableChange.UpdateColumnAutoIncrement) {
+            throw new IllegalArgumentException(
+                "Hive does not support altering column auto increment");
           } else {
             throw new IllegalArgumentException(
                 "Unsupported column change type: " + change.getClass().getSimpleName());

diff --git a/...in/java/com/datastrato/gravitino/catalog/lakehouse/iceberg/ops/IcebergTableOpsHelper.java b/...in/java/com/datastrato/gravitino/catalog/lakehouse/iceberg/ops/IcebergTableOpsHelper.java
@@ -252,6 +252,8 @@ private void alterTableColumn(
       } else if (change instanceof TableChange.UpdateColumnNullability) {
         doUpdateColumnNullability(
             icebergUpdateSchema, (TableChange.UpdateColumnNullability) change);
+      } else if (change instanceof TableChange.UpdateColumnAutoIncrement) {
+        throw new IllegalArgumentException("Iceberg doesn't support auto increment column");
       } else {
         throw new NotSupportedException(
             "Iceberg doesn't support " + change.getClass().getSimpleName() + " for now");