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 d7be1978b [KYUUBI #5529][AUTHZ][FOLLOWUP] Fix Create table ut for
Delta Lake does not trigger a sql operation
d7be1978b is described below
commit d7be1978b7b7f0d0da326c3a783b06015750aac4
Author: zml1206 <[email protected]>
AuthorDate: Thu Nov 2 10:39:32 2023 +0800
[KYUUBI #5529][AUTHZ][FOLLOWUP] Fix Create table ut for Delta Lake does not
trigger a sql operation
### _Why are the changes needed?_
Fix bug, Create table ut for Delta Lake does not trigger a sql operation.
### _How was this patch tested?_
- [ ] Add some test cases that check the changes thoroughly including
negative and positive cases if possible
- [ ] Add screenshots for manual tests if appropriate
- [x] [Run
test](https://kyuubi.readthedocs.io/en/master/contributing/code/testing.html#running-tests)
locally before make a pull request
### _Was this patch authored or co-authored using generative AI tooling?_
Closes #5597 from zml1206/KYUUBI-5529-FOLLOWUP2.
Closes #5529
9c031dc28 [zml1206] fix create table ut does not trigger a sql operation
Authored-by: zml1206 <[email protected]>
Signed-off-by: Kent Yao <[email protected]>
---
.../spark/authz/ranger/DeltaCatalogRangerSparkExtensionSuite.scala | 7 ++++---
1 file changed, 4 insertions(+), 3 deletions(-)
diff --git
a/extensions/spark/kyuubi-spark-authz/src/test/scala/org/apache/kyuubi/plugin/spark/authz/ranger/DeltaCatalogRangerSparkExtensionSuite.scala
b/extensions/spark/kyuubi-spark-authz/src/test/scala/org/apache/kyuubi/plugin/spark/authz/ranger/DeltaCatalogRangerSparkExtensionSuite.scala
index e833f03cd..405c5512d 100644
---
a/extensions/spark/kyuubi-spark-authz/src/test/scala/org/apache/kyuubi/plugin/spark/authz/ranger/DeltaCatalogRangerSparkExtensionSuite.scala
+++
b/extensions/spark/kyuubi-spark-authz/src/test/scala/org/apache/kyuubi/plugin/spark/authz/ranger/DeltaCatalogRangerSparkExtensionSuite.scala
@@ -78,7 +78,7 @@ class DeltaCatalogRangerSparkExtensionSuite extends
RangerSparkExtensionSuite {
interceptContains[AccessControlException] {
doAs(someone, sql(createNonPartitionTableSql))
}(s"does not have [create] privilege on [$namespace1/$table1]")
- doAs(admin, createNonPartitionTableSql)
+ doAs(admin, sql(createNonPartitionTableSql))
val createPartitionTableSql =
s"""
@@ -98,12 +98,13 @@ class DeltaCatalogRangerSparkExtensionSuite extends
RangerSparkExtensionSuite {
interceptContains[AccessControlException] {
doAs(someone, sql(createPartitionTableSql))
}(s"does not have [create] privilege on [$namespace1/$table2]")
- doAs(admin, createPartitionTableSql)
+ doAs(admin, sql(createPartitionTableSql))
}
}
test("create or replace table") {
withCleanTmpResources(Seq((s"$namespace1.$table1", "table"),
(s"$namespace1", "database"))) {
+ doAs(admin, sql(s"CREATE DATABASE IF NOT EXISTS $namespace1"))
val createOrReplaceTableSql =
s"""
|CREATE OR REPLACE TABLE $namespace1.$table1 (
@@ -120,7 +121,7 @@ class DeltaCatalogRangerSparkExtensionSuite extends
RangerSparkExtensionSuite {
interceptContains[AccessControlException] {
doAs(someone, sql(createOrReplaceTableSql))
}(s"does not have [create] privilege on [$namespace1/$table1]")
- doAs(admin, createOrReplaceTableSql)
+ doAs(admin, sql(createOrReplaceTableSql))
}
}