This is an automated email from the ASF dual-hosted git repository.
yao pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/kyuubi.git
The following commit(s) were added to refs/heads/master by this push:
new 4cab817913 [KYUUBI #6950] Test changing column position
4cab817913 is described below
commit 4cab8179130183fbe74faa992dd4a60f0e60ec70
Author: davidyuan <[email protected]>
AuthorDate: Tue Mar 4 16:52:25 2025 +0800
[KYUUBI #6950] Test changing column position
### Why are the changes needed?
Ranger check test case missing paimon changing column position command, add
the test case
#6950
### How was this patch tested?
Test ranger check with paimon changing column position command
### Was this patch authored or co-authored using generative AI tooling?
No
Closes #6955 from davidyuan1223/test_changing_column_position.
Closes #6950
520b5377f [davidyuan] Merge branch 'master' into
test_changing_column_position
1eed87346 [davidyuan] test changing column position
Authored-by: davidyuan <[email protected]>
Signed-off-by: Kent Yao <[email protected]>
---
.../PaimonCatalogRangerSparkExtensionSuite.scala | 37 ++++++++++++++++++++++
1 file changed, 37 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 6e11798023..cadb8ff246 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
@@ -187,6 +187,43 @@ class PaimonCatalogRangerSparkExtensionSuite extends
RangerSparkExtensionSuite {
}
}
+ test("Changing Column Position") {
+ withCleanTmpResources(Seq(
+ (s"$catalogV2.$namespace1.$table1", "table"))) {
+ val createTableSql =
+ s"""
+ |CREATE TABLE IF NOT EXISTS $catalogV2.$namespace1.$table1
+ |(id int, name string, a int, b int)
+ |USING paimon
+ |OPTIONS (
+ | 'primary-key' = 'id'
+ |)
+ |""".stripMargin
+ doAs(admin, sql(createTableSql))
+ val changingColumnPositionToFirst =
+ s"""
+ |ALTER TABLE $catalogV2.$namespace1.$table1
+ |ALTER COLUMN a FIRST
+ |""".stripMargin
+
+ interceptEndsWith[AccessControlException] {
+ doAs(someone, sql(changingColumnPositionToFirst))
+ }(s"does not have [alter] privilege on [$namespace1/$table1]")
+ doAs(admin, sql(changingColumnPositionToFirst))
+
+ val changingColumnPositionToAfter =
+ s"""
+ |ALTER TABLE $catalogV2.$namespace1.$table1
+ |ALTER COLUMN a AFTER name
+ |""".stripMargin
+
+ interceptEndsWith[AccessControlException] {
+ doAs(someone, sql(changingColumnPositionToAfter))
+ }(s"does not have [alter] privilege on [$namespace1/$table1]")
+ doAs(admin, sql(changingColumnPositionToAfter))
+ }
+ }
+
def createTableSql(namespace: String, table: String): String =
s"""
|CREATE TABLE IF NOT EXISTS $catalogV2.$namespace.$table