update

c27kwan · Jul 30, 2024 · 7b73cb1 · 7b73cb1
1 parent 3b04de5
commit 7b73cb1
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/spark/src/test/scala/org/apache/spark/sql/delta/IdentityColumnSyncSuite.scala b/spark/src/test/scala/org/apache/spark/sql/delta/IdentityColumnSyncSuite.scala
@@ -59,17 +59,18 @@ trait IdentityColumnSyncSuiteBase
   test("alter table sync identity delta") {
     val starts = Seq(-1, 1)
     val steps = Seq(-3, 3)
-    for (start <- starts; step <- steps) {
+    val alterKeywords = Seq("ALTER", "CHANGE")
+    for (start <- starts; step <- steps; alterKeyword <- alterKeywords) {
       withSimpleGeneratedByDefaultTable(start, step) {
         // Test empty table.
         val oldSchema = DeltaLog.forTable(spark, TableIdentifier(tblName)).snapshot.schema
-        sql(s"ALTER TABLE $tblName ALTER COLUMN id SYNC IDENTITY")
+        sql(s"ALTER TABLE $tblName $alterKeyword COLUMN id SYNC IDENTITY")
         assert(DeltaLog.forTable(spark, TableIdentifier(tblName)).snapshot.schema == oldSchema)
 
         // Test a series of values that are not all following start and step configurations.
         for (i <- start to (start + step * 10)) {
           sql(s"INSERT INTO $tblName VALUES($i, 'v')")
-          sql(s"ALTER TABLE $tblName ALTER COLUMN id SYNC IDENTITY")
+          sql(s"ALTER TABLE $tblName $alterKeyword COLUMN id SYNC IDENTITY")
           val expected = start + (((i - start) + (step - 1)) / step) * step
           val schema = DeltaLog.forTable(spark, TableIdentifier(tblName)).snapshot.schema
           assert(schema("id").metadata.getLong(DeltaSourceUtils.IDENTITY_INFO_HIGHWATERMARK) ==