From a10780b3a5335b0c0967fc170e10db641d1d6bbc Mon Sep 17 00:00:00 2001 From: Zhipeng Mao Date: Wed, 31 Jul 2024 12:57:50 +0200 Subject: [PATCH] Update spark/src/test/scala/org/apache/spark/sql/delta/IdentityColumnSyncSuite.scala Co-authored-by: Thang Long Vu <107926660+longvu-db@users.noreply.github.com> --- .../org/apache/spark/sql/delta/IdentityColumnSyncSuite.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 index 161f2d5202..20a54ad6a5 100644 --- a/spark/src/test/scala/org/apache/spark/sql/delta/IdentityColumnSyncSuite.scala +++ b/spark/src/test/scala/org/apache/spark/sql/delta/IdentityColumnSyncSuite.scala @@ -65,7 +65,7 @@ trait IdentityColumnSyncSuiteBase // Test empty table. val oldSchema = DeltaLog.forTable(spark, TableIdentifier(tblName)).snapshot.schema sql(s"ALTER TABLE $tblName $alterKeyword COLUMN id SYNC IDENTITY") - assert(DeltaLog.forTable(spark, TableIdentifier(tblName)).snapshot.schema == oldSchema) + 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)) {