Skip to content

Commit f481283

Browse files
committed
Revert "Update PrivilegesBuilder.scala"
This reverts commit 8785ad1.
1 parent 9f87182 commit f481283

File tree

1 file changed

+2
-4
lines changed

1 file changed

+2
-4
lines changed

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

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -111,15 +111,13 @@ object PrivilegesBuilder {
111111
case s: Sort =>
112112
val sortCols = s.order.flatMap(sortOrder => collectLeaves(sortOrder))
113113
val cols = conditionList ++ sortCols
114-
val output = projectionList ++ s.inputSet
115-
buildQuery(s.child, privilegeObjects, output, cols, spark)
114+
buildQuery(s.child, privilegeObjects, projectionList, cols, spark)
116115

117116
case a: Aggregate =>
118117
val aggCols =
119118
(a.aggregateExpressions ++ a.groupingExpressions).flatMap(e => collectLeaves(e))
120119
val cols = conditionList ++ aggCols
121-
val output = projectionList ++ a.inputSet
122-
buildQuery(a.child, privilegeObjects, output, cols, spark)
120+
buildQuery(a.child, privilegeObjects, projectionList, cols, spark)
123121

124122
case scan if isKnownScan(scan) && scan.resolved =>
125123
getScanSpec(scan).tables(scan, spark).foreach(mergeProjection(_, scan))

0 commit comments

Comments
 (0)