Skip to content

Commit a1b9d90

Browse files
committed
Fix failures in iceberg cloud tests
1 parent 5ce80be commit a1b9d90

File tree

3 files changed

+51
-1
lines changed

3 files changed

+51
-1
lines changed

plugin/trino-iceberg/src/test/java/io/trino/plugin/iceberg/catalog/BaseTrinoCatalogTest.java

Lines changed: 20 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -478,8 +478,9 @@ public void testListTables()
478478

479479
try {
480480
SchemaTableName materializedView = new SchemaTableName(ns2, "mv");
481-
catalog.createMaterializedView(
481+
createMaterializedView(
482482
SESSION,
483+
catalog,
483484
materializedView,
484485
someMaterializedView(),
485486
ImmutableMap.of(
@@ -514,6 +515,24 @@ public void testListTables()
514515
}
515516
}
516517

518+
protected void createMaterializedView(
519+
ConnectorSession session,
520+
TrinoCatalog catalog,
521+
SchemaTableName materializedView,
522+
ConnectorMaterializedViewDefinition materializedViewDefinition,
523+
Map<String, Object> properties,
524+
boolean replace,
525+
boolean ignoreExisting)
526+
{
527+
catalog.createMaterializedView(
528+
session,
529+
materializedView,
530+
materializedViewDefinition,
531+
properties,
532+
replace,
533+
ignoreExisting);
534+
}
535+
517536
protected Optional<SchemaTableName> createExternalIcebergTable(TrinoCatalog catalog, String namespace, AutoCloseableCloser closer)
518537
throws Exception
519538
{

plugin/trino-iceberg/src/test/java/io/trino/plugin/iceberg/catalog/glue/TestTrinoGlueCatalog.java

Lines changed: 23 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -35,6 +35,7 @@
3535
import io.trino.spi.connector.CatalogHandle;
3636
import io.trino.spi.connector.ConnectorMaterializedViewDefinition;
3737
import io.trino.spi.connector.ConnectorMetadata;
38+
import io.trino.spi.connector.ConnectorSession;
3839
import io.trino.spi.connector.MaterializedViewNotFoundException;
3940
import io.trino.spi.connector.SchemaTableName;
4041
import io.trino.spi.security.PrincipalType;
@@ -257,4 +258,26 @@ public void testDefaultLocation()
257258
}
258259
}
259260
}
261+
262+
@Override
263+
protected void createMaterializedView(
264+
ConnectorSession session,
265+
TrinoCatalog catalog,
266+
SchemaTableName materializedView,
267+
ConnectorMaterializedViewDefinition materializedViewDefinition,
268+
Map<String, Object> properties,
269+
boolean replace,
270+
boolean ignoreExisting)
271+
{
272+
catalog.createMaterializedView(
273+
session,
274+
materializedView,
275+
materializedViewDefinition,
276+
ImmutableMap.<String, Object>builder()
277+
.putAll(properties)
278+
.put(LOCATION_PROPERTY, "file:///tmp/a/path/" + materializedView.getTableName())
279+
.buildOrThrow(),
280+
replace,
281+
ignoreExisting);
282+
}
260283
}

plugin/trino-iceberg/src/test/java/io/trino/plugin/iceberg/catalog/snowflake/TestIcebergSnowflakeCatalogConnectorSmokeTest.java

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -684,6 +684,14 @@ public void testSnowflakeNativeTable()
684684
.hasRootCauseMessage("SQL compilation error:\ninvalid parameter 'table ? is not a Snowflake iceberg table'");
685685
}
686686

687+
@Test
688+
@Override
689+
public void testIcebergTablesFunction()
690+
{
691+
assertThatThrownBy(super::testIcebergTablesFunction)
692+
.hasMessageContaining("schemaPath is not supported for Iceberg snowflake catalog");
693+
}
694+
687695
@Override
688696
protected boolean isFileSorted(Location path, String sortColumnName)
689697
{

0 commit comments

Comments
 (0)