Skip to content

Commit 64349ed

Browse files
committed
Update PrivilegesBuilder.scala
1 parent 11b7a4c commit 64349ed

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

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

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -61,8 +61,8 @@ object PrivilegesBuilder {
6161
def buildQuery(
6262
plan: LogicalPlan,
6363
privilegeObjects: ArrayBuffer[PrivilegeObject],
64-
projectionList: Seq[Expression] = Nil,
65-
conditionList: Seq[Expression] = Nil,
64+
projectionList: Seq[NamedExpression] = Nil,
65+
conditionList: Seq[NamedExpression] = Nil,
6666
spark: SparkSession): Unit = {
6767

6868
def mergeProjection(table: Table, plan: LogicalPlan): Unit = {
@@ -121,8 +121,8 @@ object PrivilegesBuilder {
121121
buildQuery(
122122
child,
123123
privilegeObjects,
124-
columnPrune(p.expressions ++ projectionList, p.inputSet).distinct,
125-
conditionList ++ p.expressions,
124+
columnPrune(projectionList ++ p.references.toSeq, p.inputSet).distinct,
125+
conditionList ++ p.references,
126126
spark)
127127
}
128128
}

0 commit comments

Comments
 (0)