[apache#2927] Improvement(catalog-lakehouse-iceberg): Support more fi…

…le formats in using clause when create iceberg tables
caican00 · Apr 13, 2024 · 6e8af10 · 6e8af10
1 parent 65cd4ff
commit 6e8af10
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/...com/datastrato/gravitino/catalog/lakehouse/iceberg/integration/test/CatalogIcebergIT.java b/...com/datastrato/gravitino/catalog/lakehouse/iceberg/integration/test/CatalogIcebergIT.java
@@ -1085,6 +1085,7 @@ void testIcebergTablePropertiesWhenCreate() {
     Table loadTable = tableCatalog.loadTable(tableIdentifier);
     Assertions.assertFalse(loadTable.properties().containsKey(DEFAULT_FILE_FORMAT));
 
+    tableCatalog.dropTable(tableIdentifier);
     properties.put(DEFAULT_FILE_FORMAT, "iceberg");
     createdTable =
         tableCatalog.createTable(
@@ -1099,6 +1100,7 @@ void testIcebergTablePropertiesWhenCreate() {
     loadTable = tableCatalog.loadTable(tableIdentifier);
     Assertions.assertFalse(loadTable.properties().containsKey(DEFAULT_FILE_FORMAT));
 
+    tableCatalog.dropTable(tableIdentifier);
     properties.put(DEFAULT_FILE_FORMAT, "parquet");
     createdTable =
         tableCatalog.createTable(
@@ -1113,6 +1115,7 @@ void testIcebergTablePropertiesWhenCreate() {
     loadTable = tableCatalog.loadTable(tableIdentifier);
     Assertions.assertEquals("parquet", loadTable.properties().get(DEFAULT_FILE_FORMAT));
 
+    tableCatalog.dropTable(tableIdentifier);
     properties.put(DEFAULT_FILE_FORMAT, "orc");
     createdTable =
         tableCatalog.createTable(
@@ -1127,6 +1130,7 @@ void testIcebergTablePropertiesWhenCreate() {
     loadTable = tableCatalog.loadTable(tableIdentifier);
     Assertions.assertEquals("orc", loadTable.properties().get(DEFAULT_FILE_FORMAT));
 
+    tableCatalog.dropTable(tableIdentifier);
     properties.put(DEFAULT_FILE_FORMAT, "avro");
     createdTable =
         tableCatalog.createTable(
@@ -1141,6 +1145,7 @@ void testIcebergTablePropertiesWhenCreate() {
     loadTable = tableCatalog.loadTable(tableIdentifier);
     Assertions.assertEquals("avro", loadTable.properties().get(DEFAULT_FILE_FORMAT));
 
+    tableCatalog.dropTable(tableIdentifier);
     properties.put(DEFAULT_FILE_FORMAT, "text");
     Assertions.assertThrows(
         IllegalArgumentException.class,