MaxGekk commented on code in PR #38134:
URL: https://github.com/apache/spark/pull/38134#discussion_r989101810
##########
sql/core/src/test/scala/org/apache/spark/sql/execution/command/v2/AlterTableAddPartitionSuite.scala:
##########
@@ -99,4 +100,22 @@ class AlterTableAddPartitionSuite
}
}
}
+
+ // TODO: Move this test to the common trait as soon as it is migrated on
checkError()
+ test("partition already exists") {
+ withNamespaceAndTable("ns", "tbl") { t =>
+ sql(s"CREATE TABLE $t (id bigint, data string) $defaultUsing PARTITIONED
BY (id)")
+ sql(s"ALTER TABLE $t ADD PARTITION (id=2) LOCATION 'loc1'")
+
+ val errMsg = intercept[PartitionsAlreadyExistException] {
+ sql(s"ALTER TABLE $t ADD PARTITION (id=1) LOCATION 'loc'" +
+ " PARTITION (id=2) LOCATION 'loc1'")
+ }.getMessage
+ assert(errMsg === s"The following partitions already exists in table
$t:2 -> id")
Review Comment:
Here is another mistake. Must be `id -> 2`, I think. I will fix this
separately as soon as I have this test in.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
