From 45adcf03f433db42b7abee1a3f95d4d972e20295 Mon Sep 17 00:00:00 2001 From: fanng Date: Tue, 9 Jul 2024 15:53:55 +0800 Subject: [PATCH] fix comment --- .../test/IcebergRESTServiceIT.java | 21 ++++++++++++------- 1 file changed, 14 insertions(+), 7 deletions(-) diff --git a/iceberg-rest-server/src/test/java/com/datastrato/gravitino/iceberg/integration/test/IcebergRESTServiceIT.java b/iceberg-rest-server/src/test/java/com/datastrato/gravitino/iceberg/integration/test/IcebergRESTServiceIT.java index 9dfb3936b87..bd82d3279d3 100644 --- a/iceberg-rest-server/src/test/java/com/datastrato/gravitino/iceberg/integration/test/IcebergRESTServiceIT.java +++ b/iceberg-rest-server/src/test/java/com/datastrato/gravitino/iceberg/integration/test/IcebergRESTServiceIT.java @@ -67,8 +67,10 @@ private void purgeTable(String namespace, String table) { private void purgeNameSpace(String namespace) { Set tables = convertToStringSet(sql("SHOW TABLES IN " + namespace), 1); - tables.stream().filter( - // the original table and registered table share one metadata, so couldn't purge two tables. + tables.stream() + .filter( + // the original table and registered table share one metadata, so couldn't purge two + // tables. table -> !table.equals(ICEBERG_REGISTER_TABLE_NAME)) .forEach(table -> purgeTable(namespace, table)); sql("DROP database " + namespace); @@ -529,16 +531,21 @@ void testSnapshot() { @EnabledIf("catalogTypeNotMemory") void testRegisterTable() { sql( - "CREATE TABLE iceberg_rest_table_test." + ICEBERG_REGISTER_TABLE_NAME + "CREATE TABLE iceberg_rest_table_test." + + ICEBERG_REGISTER_TABLE_NAME + " (id bigint COMMENT 'unique id',data string) using iceberg"); - sql(String.format("INSERT INTO iceberg_rest_table_test.%s VALUES (1, 'a')", - ICEBERG_REGISTER_TABLE_NAME)); + sql( + String.format( + "INSERT INTO iceberg_rest_table_test.%s VALUES (1, 'a')", ICEBERG_REGISTER_TABLE_NAME)); // get metadata location List metadataLocations = convertToStringList( - sql(String.format("select file from iceberg_rest_table_test.%s.metadata_log_entries", - ICEBERG_REGISTER_TABLE_NAME)), 0); + sql( + String.format( + "select file from iceberg_rest_table_test.%s.metadata_log_entries", + ICEBERG_REGISTER_TABLE_NAME)), + 0); String metadataLocation = metadataLocations.get(metadataLocations.size() - 1); // register table