Skip to content

Commit 93466e2

Browse files
committed
fix ut
1 parent 9a737a3 commit 93466e2

File tree

1 file changed

+0
-18
lines changed

1 file changed

+0
-18
lines changed

extensions/spark/kyuubi-spark-connector-hive/src/test/scala/org/apache/kyuubi/spark/connector/hive/command/PartitionManagementSuite.scala

Lines changed: 0 additions & 18 deletions
Original file line numberDiff line numberDiff line change
@@ -105,22 +105,4 @@ class PartitionManagementV1Suite extends PartitionManagementSuite {
105105
override protected val catalogName: String = SESSION_CATALOG_NAME
106106
override protected def catalogVersion: String = "V1"
107107
override protected def commandVersion: String = V1_COMMAND_VERSION
108-
109-
test("create partition with location") {
110-
withNamespaceAndTable("ns", "tbl") { t =>
111-
sql(s"CREATE TABLE $t (id string, year string, month string) PARTITIONED BY (year, month)")
112-
val loc = "file:///tmp/kyuubi/hive_catalog_part_loc"
113-
sql(s"ALTER TABLE $t ADD PARTITION (year='2023', month='01') LOCATION '$loc'")
114-
checkAnswer(
115-
sql(s"SHOW PARTITIONS $t"),
116-
Row("year=2023/month=01") :: Nil)
117-
val partition = spark.sessionState.catalog.externalCatalog.getPartition(
118-
"ns",
119-
"tbl",
120-
Map("year" -> "2023", "month" -> "01"))
121-
val locationUri = partition.storage.locationUri
122-
assert(locationUri.isDefined)
123-
assert(locationUri.get.toString.contains("hive_catalog_part_loc"))
124-
}
125-
}
126108
}

0 commit comments

Comments
 (0)