Skip to content

Commit 9f87182

Browse files
committed
Revert "Update PrivilegesBuilder.scala"
This reverts commit 29b67c4.
1 parent 29b67c4 commit 9f87182

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

extensions/spark/kyuubi-spark-authz/src/main/scala/org/apache/kyuubi/plugin/spark/authz/PrivilegesBuilder.scala

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -67,7 +67,8 @@ object PrivilegesBuilder {
6767
def mergeProjection(table: Table, plan: LogicalPlan): Unit = {
6868
if (projectionList.isEmpty) {
6969
plan match {
70-
case pvm: PermanentViewMarker =>
70+
case pvm: PermanentViewMarker
71+
if pvm.isSubqueryExpressionPlaceHolder || pvm.output.isEmpty =>
7172
privilegeObjects += PrivilegeObject(table, pvm.outputColNames)
7273
case _ =>
7374
privilegeObjects += PrivilegeObject(table, plan.output.map(_.name))
@@ -132,7 +133,8 @@ object PrivilegesBuilder {
132133
case p =>
133134
for (child <- p.children) {
134135
child match {
135-
case pvm: PermanentViewMarker =>
136+
case pvm: PermanentViewMarker
137+
if pvm.isSubqueryExpressionPlaceHolder || pvm.output.isEmpty =>
136138
buildQuery(child, privilegeObjects, projectionList, conditionList, spark)
137139
case _ =>
138140
val childCols = columnPrune(projectionList ++ conditionList, child.outputSet)

0 commit comments

Comments
 (0)