From 4b160d720e14b618afac85611a56291e626035a1 Mon Sep 17 00:00:00 2001 From: davidyuan Date: Thu, 20 Feb 2025 21:39:04 +0800 Subject: [PATCH 1/3] support create partition table as for paimon --- ...imonCatalogRangerSparkExtensionSuite.scala | 21 +++++++++++++++++++ 1 file changed, 21 insertions(+) diff --git a/extensions/spark/kyuubi-spark-authz/src/test/scala/org/apache/kyuubi/plugin/spark/authz/ranger/PaimonCatalogRangerSparkExtensionSuite.scala b/extensions/spark/kyuubi-spark-authz/src/test/scala/org/apache/kyuubi/plugin/spark/authz/ranger/PaimonCatalogRangerSparkExtensionSuite.scala index 841520aeb96..303953b7bfe 100644 --- a/extensions/spark/kyuubi-spark-authz/src/test/scala/org/apache/kyuubi/plugin/spark/authz/ranger/PaimonCatalogRangerSparkExtensionSuite.scala +++ b/extensions/spark/kyuubi-spark-authz/src/test/scala/org/apache/kyuubi/plugin/spark/authz/ranger/PaimonCatalogRangerSparkExtensionSuite.scala @@ -121,6 +121,27 @@ class PaimonCatalogRangerSparkExtensionSuite extends RangerSparkExtensionSuite { } } + test("CTPartition") { + withCleanTmpResources(Seq( + (s"$catalogV2.$namespace1.$table1", "table"))) { + val createPartitionTableSql = + s""" + |CREATE TABLE IF NOT EXISTS $catalogV2.$namespace1.$table1 + |(id INT, name STRING, dt STRING, hh STRING) + | USING paimon + | PARTITIONED BY (dt, hh) + | OPTIONS ( + | 'primary-key' = 'id' + | ) + |""".stripMargin + + interceptEndsWith[AccessControlException] { + doAs(someone, sql(createPartitionTableSql)) + }(s"does not have [create] privilege on [$namespace1/$table1]") + doAs(admin, sql(createPartitionTableSql)) + } + } + def createTableSql(namespace: String, table: String): String = s""" |CREATE TABLE IF NOT EXISTS $catalogV2.$namespace.$table From b0829795abe30eaafeb1711f4f98cdd0b056e64a Mon Sep 17 00:00:00 2001 From: Bowen Liang Date: Fri, 21 Feb 2025 09:52:46 +0800 Subject: [PATCH 2/3] Update extensions/spark/kyuubi-spark-authz/src/test/scala/org/apache/kyuubi/plugin/spark/authz/ranger/PaimonCatalogRangerSparkExtensionSuite.scala --- .../authz/ranger/PaimonCatalogRangerSparkExtensionSuite.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/extensions/spark/kyuubi-spark-authz/src/test/scala/org/apache/kyuubi/plugin/spark/authz/ranger/PaimonCatalogRangerSparkExtensionSuite.scala b/extensions/spark/kyuubi-spark-authz/src/test/scala/org/apache/kyuubi/plugin/spark/authz/ranger/PaimonCatalogRangerSparkExtensionSuite.scala index 303953b7bfe..236a110d12c 100644 --- a/extensions/spark/kyuubi-spark-authz/src/test/scala/org/apache/kyuubi/plugin/spark/authz/ranger/PaimonCatalogRangerSparkExtensionSuite.scala +++ b/extensions/spark/kyuubi-spark-authz/src/test/scala/org/apache/kyuubi/plugin/spark/authz/ranger/PaimonCatalogRangerSparkExtensionSuite.scala @@ -121,7 +121,7 @@ class PaimonCatalogRangerSparkExtensionSuite extends RangerSparkExtensionSuite { } } - test("CTPartition") { + test("Create Partioned Table") { withCleanTmpResources(Seq( (s"$catalogV2.$namespace1.$table1", "table"))) { val createPartitionTableSql = From ffb79376ff399875c5267a82bcc686856e104462 Mon Sep 17 00:00:00 2001 From: Cheng Pan Date: Mon, 24 Feb 2025 14:32:59 +0800 Subject: [PATCH 3/3] Update extensions/spark/kyuubi-spark-authz/src/test/scala/org/apache/kyuubi/plugin/spark/authz/ranger/PaimonCatalogRangerSparkExtensionSuite.scala --- .../authz/ranger/PaimonCatalogRangerSparkExtensionSuite.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/extensions/spark/kyuubi-spark-authz/src/test/scala/org/apache/kyuubi/plugin/spark/authz/ranger/PaimonCatalogRangerSparkExtensionSuite.scala b/extensions/spark/kyuubi-spark-authz/src/test/scala/org/apache/kyuubi/plugin/spark/authz/ranger/PaimonCatalogRangerSparkExtensionSuite.scala index 236a110d12c..18318c2784f 100644 --- a/extensions/spark/kyuubi-spark-authz/src/test/scala/org/apache/kyuubi/plugin/spark/authz/ranger/PaimonCatalogRangerSparkExtensionSuite.scala +++ b/extensions/spark/kyuubi-spark-authz/src/test/scala/org/apache/kyuubi/plugin/spark/authz/ranger/PaimonCatalogRangerSparkExtensionSuite.scala @@ -121,7 +121,7 @@ class PaimonCatalogRangerSparkExtensionSuite extends RangerSparkExtensionSuite { } } - test("Create Partioned Table") { + test("CREATE PARTITIONED Table") { withCleanTmpResources(Seq( (s"$catalogV2.$namespace1.$table1", "table"))) { val createPartitionTableSql =