update

Author: davidyuan1223

extensions/spark/kyuubi-spark-authz/src/main/resources/table_command_spec.json

@@ -1815,12 +1815,7 @@
     "fieldName" : "table",
     "fieldExtractor" : "ArrayBufferTableExtractor",
     "columnDesc" : null,
-    "actionTypeDesc" : {
-      "fieldName" : null,
-      "fieldExtractor" : null,
-      "actionType" : "UPDATE",
-      "comment" : ""
-    },
+    "actionTypeDesc" : null,
     "tableTypeDesc" : null,
     "catalogDesc" : null,
     "isInput" : false,

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

@@ -189,15 +189,15 @@ class ExpressionSeqTableExtractor extends TableExtractor {
  */
 class ArrayBufferTableExtractor extends TableExtractor {
   override def apply(spark: SparkSession, v1: AnyRef): Option[Table] = {
-    // Iceberg will transform table to ArrayBuffer
-    val expressions = v1.asInstanceOf[Seq[Expression]]
+    // Iceberg will transform table to ArrayBuffer[String]
+    val expressions = v1.asInstanceOf[Seq[String]]
     val maybeTable = expressions.length match {
-      case 1 => Table(None, None, expressions.head.toString(), None)
-      case 2 => Table(None, Some(expressions.head.toString()), expressions(1).toString(), None)
+      case 1 => Table(None, None, expressions.head, None)
+      case 2 => Table(None, Some(expressions.head), expressions(1), None)
       case 3 => Table(
-          Some(expressions.head.toString()),
-          Some(expressions(1).toString()),
-          expressions(2).toString(),
+          Some(expressions.head),
+          Some(expressions(1)),
+          expressions(2),
           None)
     }
     Option(maybeTable)

extensions/spark/kyuubi-spark-authz/src/test/scala/org/apache/kyuubi/plugin/spark/authz/gen/IcebergCommands.scala

@@ -60,12 +60,10 @@ object IcebergCommands extends CommandSpecs[TableCommandSpec] {
 
   val AddPartitionFiled = {
     val cmd = "org.apache.spark.sql.catalyst.plans.logical.AddPartitionField"
-    val actionTypeDesc = ActionTypeDesc(actionType = Some(UPDATE))
     val tableDesc =
       TableDesc(
         "table",
         classOf[ArrayBufferTableExtractor],
-        actionTypeDesc = Some(actionTypeDesc),
         comment = "Iceberg")
     TableCommandSpec(cmd, Seq(tableDesc), opType = OperationType.ALTERTABLE_PROPERTIES)
   }

extensions/spark/kyuubi-spark-authz/src/test/scala/org/apache/kyuubi/plugin/spark/authz/ranger/IcebergCatalogRangerSparkExtensionSuite.scala

@@ -381,14 +381,16 @@ class IcebergCatalogRangerSparkExtensionSuite extends RangerSparkExtensionSuite
 
   test("ALTER TABLE ADD PARTITION FIELD for Iceberg") {
     val table = s"$catalogV2.$namespace1.partitioned_table"
-    doAs(
-      admin,
-      sql(
-        s"CREATE TABLE $table (id int, name string, city string) USING iceberg PARTITIONED BY (city)"))
-    val addPartitionSql = s"ALTER TABLE $table ADD PARTITION FIELD id"
-    interceptEndsWith[AccessControlException] {
-      doAs(someone, sql(addPartitionSql))
-    }(s"does not have [alter] privilege on [$namespace1/partitioned_table]")
-    doAs(someone, sql(addPartitionSql))
+    withCleanTmpResources(Seq((table, "table"))) {
+      doAs(
+        admin,
+        sql(
+          s"CREATE TABLE $table (id int, name string, city string) USING iceberg PARTITIONED BY (city)"))
+      val addPartitionSql = s"ALTER TABLE $table ADD PARTITION FIELD id"
+      interceptEndsWith[AccessControlException] {
+        doAs(someone, sql(addPartitionSql))
+      }(s"does not have [alter] privilege on [$namespace1/partitioned_table]")
+      doAs(admin, sql(addPartitionSql))
+    }
   }
 }