diff --git a/plugin/trino-hive/src/main/java/io/trino/plugin/hive/HiveMetadata.java b/plugin/trino-hive/src/main/java/io/trino/plugin/hive/HiveMetadata.java index 3634363ad3b3..703b6ec6d3f2 100644 --- a/plugin/trino-hive/src/main/java/io/trino/plugin/hive/HiveMetadata.java +++ b/plugin/trino-hive/src/main/java/io/trino/plugin/hive/HiveMetadata.java @@ -2443,20 +2443,8 @@ public Optional getView(ConnectorSession session, Schem throw new HiveViewNotSupportedException(viewName); } - ConnectorViewDefinition definition = createViewReader(metastore, session, view, typeManager, this::redirectTable, metadataProvider, hiveViewsRunAsInvoker) + return createViewReader(metastore, session, view, typeManager, this::redirectTable, metadataProvider, hiveViewsRunAsInvoker) .decodeViewData(view.getViewOriginalText().get(), view, catalogName); - // use owner from table metadata if it exists - if (view.getOwner().isPresent() && !definition.isRunAsInvoker()) { - definition = new ConnectorViewDefinition( - definition.getOriginalSql(), - definition.getCatalog(), - definition.getSchema(), - definition.getColumns(), - definition.getComment(), - view.getOwner(), - false); - } - return definition; }); } diff --git a/plugin/trino-hive/src/main/java/io/trino/plugin/hive/LegacyHiveViewReader.java b/plugin/trino-hive/src/main/java/io/trino/plugin/hive/LegacyHiveViewReader.java index 622b1ff54fa8..823ff9719482 100644 --- a/plugin/trino-hive/src/main/java/io/trino/plugin/hive/LegacyHiveViewReader.java +++ b/plugin/trino-hive/src/main/java/io/trino/plugin/hive/LegacyHiveViewReader.java @@ -49,7 +49,7 @@ public ConnectorViewDefinition decodeViewData(String viewData, Table table, Cata .map(column -> new ConnectorViewDefinition.ViewColumn(column.getName(), TypeId.of(column.getType().getTypeSignature().toString()))) .collect(toImmutableList()), Optional.ofNullable(table.getParameters().get(TABLE_COMMENT)), - table.getOwner(), + hiveViewsRunAsInvoker ? Optional.empty() : table.getOwner(), hiveViewsRunAsInvoker); } } diff --git a/plugin/trino-hive/src/main/java/io/trino/plugin/hive/ViewReaderUtil.java b/plugin/trino-hive/src/main/java/io/trino/plugin/hive/ViewReaderUtil.java index 9f053a48c0b5..073b18a78afd 100644 --- a/plugin/trino-hive/src/main/java/io/trino/plugin/hive/ViewReaderUtil.java +++ b/plugin/trino-hive/src/main/java/io/trino/plugin/hive/ViewReaderUtil.java @@ -226,7 +226,7 @@ public ConnectorViewDefinition decodeViewData(String viewSql, Table table, Catal Optional.of(table.getDatabaseName()), columns, Optional.ofNullable(table.getParameters().get(TABLE_COMMENT)), - Optional.empty(), + hiveViewsRunAsInvoker ? Optional.empty() : table.getOwner(), hiveViewsRunAsInvoker); } catch (RuntimeException e) {