diff --git a/core/trino-main/src/main/java/io/trino/sql/planner/LogicalPlanner.java b/core/trino-main/src/main/java/io/trino/sql/planner/LogicalPlanner.java index 6fef2cecb267..2ff6b7c303e8 100644 --- a/core/trino-main/src/main/java/io/trino/sql/planner/LogicalPlanner.java +++ b/core/trino-main/src/main/java/io/trino/sql/planner/LogicalPlanner.java @@ -588,7 +588,7 @@ private RelationPlan createRefreshMaterializedViewPlan(Analysis analysis) Query query = viewAnalysis.getQuery(); Optional newTableLayout = metadata.getInsertLayout(session, viewAnalysis.getTarget()); TableWriterNode.RefreshMaterializedViewReference writerTarget = new TableWriterNode.RefreshMaterializedViewReference( - viewAnalysis.getTable(), + viewAnalysis.getTable().toString(), tableHandle, new ArrayList<>(analysis.getTables())); return getInsertPlan(analysis, viewAnalysis.getTable(), query, tableHandle, viewAnalysis.getColumns(), newTableLayout, Optional.of(writerTarget)); diff --git a/core/trino-main/src/main/java/io/trino/sql/planner/plan/TableWriterNode.java b/core/trino-main/src/main/java/io/trino/sql/planner/plan/TableWriterNode.java index 6c0f8820983e..e9bd89a9eba3 100644 --- a/core/trino-main/src/main/java/io/trino/sql/planner/plan/TableWriterNode.java +++ b/core/trino-main/src/main/java/io/trino/sql/planner/plan/TableWriterNode.java @@ -36,7 +36,6 @@ import io.trino.spi.type.Type; import io.trino.sql.planner.PartitioningScheme; import io.trino.sql.planner.Symbol; -import io.trino.sql.tree.Table; import javax.annotation.concurrent.Immutable; @@ -437,22 +436,17 @@ public boolean supportsMultipleWritersPerPartition(Metadata metadata, Session se public static class RefreshMaterializedViewReference extends WriterTarget { - private final Table table; + private final String table; private final TableHandle storageTableHandle; private final List sourceTableHandles; - public RefreshMaterializedViewReference(Table table, TableHandle storageTableHandle, List sourceTableHandles) + public RefreshMaterializedViewReference(String table, TableHandle storageTableHandle, List sourceTableHandles) { this.table = requireNonNull(table, "table is null"); this.storageTableHandle = requireNonNull(storageTableHandle, "storageTableHandle is null"); this.sourceTableHandles = ImmutableList.copyOf(sourceTableHandles); } - public Table getTable() - { - return table; - } - public TableHandle getStorageTableHandle() { return storageTableHandle; @@ -466,7 +460,7 @@ public List getSourceTableHandles() @Override public String toString() { - return table.toString(); + return table; } @Override