From b181deea943dd95f17dc2419290b3f09aeeb0f54 Mon Sep 17 00:00:00 2001 From: wforget <643348094@qq.com> Date: Sat, 7 Oct 2023 11:27:35 +0800 Subject: [PATCH] make kyuubi-spark-authz plugin compatible with Spark3.5 --- .../src/main/resources/table_command_spec.json | 4 ++-- .../apache/kyuubi/plugin/spark/authz/gen/TableCommands.scala | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/extensions/spark/kyuubi-spark-authz/src/main/resources/table_command_spec.json b/extensions/spark/kyuubi-spark-authz/src/main/resources/table_command_spec.json index 70c9d40206e..06d76c7e530 100644 --- a/extensions/spark/kyuubi-spark-authz/src/main/resources/table_command_spec.json +++ b/extensions/spark/kyuubi-spark-authz/src/main/resources/table_command_spec.json @@ -178,7 +178,7 @@ "isInput" : false, "setCurrentDatabaseIfMissing" : false }, { - "fieldName" : "left", + "fieldName" : "name", "fieldExtractor" : "ResolvedDbObjectNameTableExtractor", "columnDesc" : null, "actionTypeDesc" : null, @@ -529,7 +529,7 @@ "isInput" : false, "setCurrentDatabaseIfMissing" : false }, { - "fieldName" : "left", + "fieldName" : "name", "fieldExtractor" : "ResolvedDbObjectNameTableExtractor", "columnDesc" : null, "actionTypeDesc" : null, diff --git a/extensions/spark/kyuubi-spark-authz/src/test/scala/org/apache/kyuubi/plugin/spark/authz/gen/TableCommands.scala b/extensions/spark/kyuubi-spark-authz/src/test/scala/org/apache/kyuubi/plugin/spark/authz/gen/TableCommands.scala index ca2ee92948e..6a6800210dc 100644 --- a/extensions/spark/kyuubi-spark-authz/src/test/scala/org/apache/kyuubi/plugin/spark/authz/gen/TableCommands.scala +++ b/extensions/spark/kyuubi-spark-authz/src/test/scala/org/apache/kyuubi/plugin/spark/authz/gen/TableCommands.scala @@ -234,9 +234,9 @@ object TableCommands { TableCommandSpec( cmd, Seq( - resolvedIdentifierTableDesc.copy(fieldName = "left"), + resolvedIdentifierTableDesc.copy(fieldName = "name"), tableDesc, - resolvedDbObjectNameDesc.copy(fieldName = "left")), + resolvedDbObjectNameDesc.copy(fieldName = "name")), CREATETABLE_AS_SELECT, Seq(queryQueryDesc)) }