From ec70948da143156d369a3a195a9acb7fa134b65f Mon Sep 17 00:00:00 2001 From: lukasz-stec Date: Mon, 30 Dec 2024 10:32:07 +0100 Subject: [PATCH] Test iceberg_tables function with TrinoSnowflakeCatalog --- .../TestIcebergSnowflakeCatalogConnectorSmokeTest.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/plugin/trino-iceberg/src/test/java/io/trino/plugin/iceberg/catalog/snowflake/TestIcebergSnowflakeCatalogConnectorSmokeTest.java b/plugin/trino-iceberg/src/test/java/io/trino/plugin/iceberg/catalog/snowflake/TestIcebergSnowflakeCatalogConnectorSmokeTest.java index 2488a1c683b5..56937024f6cf 100644 --- a/plugin/trino-iceberg/src/test/java/io/trino/plugin/iceberg/catalog/snowflake/TestIcebergSnowflakeCatalogConnectorSmokeTest.java +++ b/plugin/trino-iceberg/src/test/java/io/trino/plugin/iceberg/catalog/snowflake/TestIcebergSnowflakeCatalogConnectorSmokeTest.java @@ -688,8 +688,8 @@ public void testSnowflakeNativeTable() @Override public void testIcebergTablesFunction() { - assertThatThrownBy(super::testIcebergTablesFunction) - .hasMessageContaining("schemaPath is not supported for Iceberg snowflake catalog"); + assertThat(query("SELECT * FROM TABLE(iceberg.system.iceberg_tables(SCHEMA_NAME => '%s'))".formatted(SNOWFLAKE_TEST_SCHEMA.toLowerCase(ENGLISH)))) + .matches("SELECT table_schema, table_name FROM iceberg.information_schema.tables WHERE table_schema='%s'".formatted(SNOWFLAKE_TEST_SCHEMA.toLowerCase(ENGLISH))); } @Override